package com.wicket.okrapp.biz.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.wicket.okrapp.biz.service.*;
import com.wicket.okrapp.biz.service.dto.req.*;
import com.wicket.okrapp.biz.service.dto.res.*;
import com.wicket.okrapp.common.exception.BizException;
import com.wicket.okrapp.common.util.CommonFunctionHelper;
import com.wicket.okrapp.common.util.RedisUtil;
import java.util.List;
import java.util.stream.Collectors;
import javax.annotation.Resource;

import com.wicket.okrcomponent.integration.dto.*;
import com.wicket.okrcomponent.integration.dto.QueryConfItemMatchAnswerDetailComReqDto;
import com.wicket.okrframework.base.service.dto.req.DeptDto;
import com.wicket.okrframework.integration.dto.*;
import org.apache.skywalking.apm.toolkit.trace.Tag;
import org.apache.skywalking.apm.toolkit.trace.Tags;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.wicket.okrapp.common.exception.Assert;
import com.wicket.okrapp.base.service.MOmsOfficialDocumentService;
import com.wicket.okrapp.dal.po.mbg.OmsOfficialDocument;
import com.wicket.okrapp.base.service.dto.req.QueryOfficialDocumentDetailReq;
import com.wicket.okrapp.base.service.dto.req.QueryOfficialDocumentListReq;
import com.wicket.okrapp.biz.service.dto.common.OfficialDocumentDto;
import java.util.ArrayList;
import com.wicket.okrapp.base.service.dto.req.ImplementVagueQueryOfficialDocumentReq;
import cn.hutool.core.collection.CollectionUtil;
import com.wicket.okrframework.integration.FwBaseInductionRecordClient;
import com.wicket.okrframework.integration.FwBaseBatchClient;
import com.wicket.okrapp.base.service.dto.req.BatchQueryVagueQueryOfficialDocumentReq;
import com.wicket.okrapp.biz.service.dto.common.MyReceiveOfficialDocumentDto;
import com.wicket.okrcomponent.integration.FwCompMessageClient;
import com.wicket.okrapp.biz.service.dto.common.AnnexDto;
import com.wicket.okrcomponent.integration.FwCompUnstructuredDataClient;
import com.wicket.okrcomponent.integration.FwCompInterfaceModeClient;
import com.wicket.okrapp.base.service.MOmsEvaluationObjectTargetCycleService;
import com.wicket.okrapp.biz.service.nb.NbOfficialDocument;
import com.wicket.okrframework.integration.FwBaseOrgClient;
import com.wicket.okrcomponent.integration.FwCompDataSetSingleEntryClient;
import com.wicket.okrcomponent.integration.FwCompConfSchemeClient;

/**
 * @author ：
 * @date ：
 *
 *
 * @version 1.0
 */
@Service
public class OfficialDocumentServiceImpl
  implements com.wicket.okrapp.biz.service.OfficialDocumentService {

  @Resource
  private RedisUtil redisUtil;
@Resource
  private MOmsOfficialDocumentService mOmsOfficialDocumentService;
@Resource
  private FwBaseInductionRecordClient fwBaseInductionRecordClient;
@Resource
  private FwBaseBatchClient fwBaseBatchClient;
@Resource
  private FwCompMessageClient fwCompMessageClient;
@Resource
  private UnstructuredDataService unstructuredDataService;
@Resource
  private FwCompUnstructuredDataClient fwCompUnstructuredDataClient;
@Resource
  private FwCompInterfaceModeClient fwCompInterfaceModeClient;
@Resource
  private PlanDataService planDataService;
@Resource
  private MOmsEvaluationObjectTargetCycleService mOmsEvaluationObjectTargetCycleService;
@Resource
  private NbOfficialDocument nbOfficialDocument;
@Resource
  private WorkTasksService workTasksService;
@Resource
  private FwBaseOrgClient fwBaseOrgClient;
@Resource
  private VirtualOrgService virtualOrgService;
@Resource
  private MessageService messageService;
@Resource
  private FwCompDataSetSingleEntryClient fwCompDataSetSingleEntryClient;
@Resource
  private FwCompConfSchemeClient fwCompConfSchemeClient;
//@Resource
 //private MSpecMethordTableService mSpecMethordTableService;
/**
   * D3修改公文[7928]
   * gen by moon at 7/18/2024, 6:34:32 PM
   */
  @Trace(operationName = "D3修改公文")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public UpdateOfficialDocumentRespDto updateOfficialDocument(UpdateOfficialDocumentReqDto reqDto){
    
      
      //virtualUsage D3-9修改公文主体(公共)  53522
      UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto = null;
    UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto=new UpdateOfficialDocumentBodyComReqDto();
  if(reqDto!=null){
      updateOfficialDocumentBodyComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311574_1_53522
updateOfficialDocumentBodyComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311575_1_53522
updateOfficialDocumentBodyComReqDto.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1385476_1_53522
updateOfficialDocumentBodyComReqDto.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311578_1_53522
updateOfficialDocumentBodyComReqDto.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311581_1_53522
updateOfficialDocumentBodyComReqDto.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311582_1_53522
    }
  
    /*D3-9修改公文主体(公共)[7923]   */
    Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentId(),"D3修改公文-D3-9修改公文主体(公共)-公文ID不能为空",false);
      updateOfficialDocumentBodyComRespDto = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      
if((reqDto!= null&& reqDto.getOfficialDocumentUnstructuredDataId() != null )) {
        //if(D3修改公文.公文文档ID 值不等于空 )  53635

ImplementSingleMultipleFieldSetDataEntryComRespDto implementSingleMultipleFieldSetDataEntryComRespDto = null;
    ImplementSingleMultipleFieldSetDataEntryComReqDto implementSingleMultipleFieldSetDataEntryComReqDto=new ImplementSingleMultipleFieldSetDataEntryComReqDto();
if(reqDto!=null){
      implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField1(reqDto.getOfficialDocumentUnstructuredDataId());//SimpleFieldAssign//sourceId:1857014_1_69766
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField2(reqDto.getPostfix());//SimpleFieldAssign//sourceId:1857015_1_69766
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField3(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1857016_1_69766
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField4(reqDto.getSourceRelationshipId());//SimpleFieldAssign//sourceId:1857017_1_69766
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField5(reqDto.getRelationshipType());//SimpleFieldAssign//sourceId:1857018_1_69766
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField6(reqDto.getIsNetworkReference());//SimpleFieldAssign//sourceId:1857019_1_69766
    }

    /*D2执行单条多字段转数据集(公共)[9762]   */
    Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField1(),"D3修改公文-D2执行单条多字段转数据集(公共)-自定义字段1不能为空",false);
Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField2(),"D3修改公文-D2执行单条多字段转数据集(公共)-自定义字段2不能为空",false);
Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField3(),"D3修改公文-D2执行单条多字段转数据集(公共)-自定义字段3不能为空",false);
      implementSingleMultipleFieldSetDataEntryComRespDto = fwCompDataSetSingleEntryClient.implementSingleMultipleFieldSetDataEntryCom(implementSingleMultipleFieldSetDataEntryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto = null;
    if(implementSingleMultipleFieldSetDataEntryComRespDto !=null){
          ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto=new ImplementSeparateAddOrDeleteDocListComReqDto();
  implementSeparateAddOrDeleteDocListComReqDto.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934778_1_69762
  implementSeparateAddOrDeleteDocListComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1856870_1_69762
implementSeparateAddOrDeleteDocListComReqDto.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1856871_1_69762
implementSeparateAddOrDeleteDocListComReqDto.setIsResult("FALSE");//sourceId:1859369_1_69762
implementSeparateAddOrDeleteDocListComReqDto.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1856873_1_69762
implementSeparateAddOrDeleteDocListComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1856879_1_69762
implementSeparateAddOrDeleteDocListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1856868_1_69762
if(implementSingleMultipleFieldSetDataEntryComRespDto!= null&&  implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList() !=null&& !CollectionUtil.isEmpty(implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList())){
      implementSeparateAddOrDeleteDocListComReqDto.setDocumentList(//objList-to-objLists
        implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList().stream().map(item -> {
            com.wicket.okrcomponent.integration.dto.DocumentDto elm = new com.wicket.okrcomponent.integration.dto.DocumentDto();
      if(item!=null){
      elm.setUnstructuredDataId(item.getCustomField1());//SimpleFieldAssign//sourceId:371956_2_69762
elm.setPostfix(item.getCustomField2());//SimpleFieldAssign//sourceId:371960_2_69762
elm.setFileRelativePathAccess(item.getCustomField3());//SimpleFieldAssign//sourceId:371961_2_69762
elm.setSourceRelationshipId(item.getCustomField4());//SimpleFieldAssign//sourceId:371957_2_69762
elm.setRelationshipType(item.getCustomField5());//SimpleFieldAssign//sourceId:371958_2_69762
elm.setIsNetworkReference(item.getCustomField6());//SimpleFieldAssign//sourceId:371959_2_69762
    }
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1856869_1_69762
    }
if(reqDto!=null){
      implementSeparateAddOrDeleteDocListComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1856867_1_69762
    }

    /*D2新增或删除公文文档列表(公共)[8783]   */
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsCleanPersonalInvalidDocument(),"D3修改公文-D2新增或删除公文文档列表(公共)-是否清理个人无效文档不能为空",false);
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseSceneCode(),"D3修改公文-D2新增或删除公文文档列表(公共)-文档应用业务场景不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseType(),"D3修改公文-D2新增或删除公文文档列表(公共)-文档用途类型不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsResult(),"D3修改公文-D2新增或删除公文文档列表(公共)-冗余是否结果文档不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnEntityId(),"D3修改公文-D2新增或删除公文文档列表(公共)-归属内容表主键ID不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnTableTypeCode(),"D3修改公文-D2新增或删除公文文档列表(公共)-归属内容表类型编码不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getUserId(),"D3修改公文-D2新增或删除公文文档列表(公共)-归属个人账号不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getSpaceId(),"D3修改公文-D2新增或删除公文文档列表(公共)-创建于空间ID不能为空",false);
      implementSeparateAddOrDeleteDocListComRespDto = fwCompUnstructuredDataClient.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }
UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto_1 = null;
          UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto_1=new UpdateOfficialDocumentBodyComReqDto();
  if(reqDto!=null){
      updateOfficialDocumentBodyComReqDto_1.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311574_1_53781
updateOfficialDocumentBodyComReqDto_1.setOfficialDocumentFileAddress(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1385546_1_53781
    }

    /*D3-9修改公文主体(公共)[7923]   */
    Assert.isNull(updateOfficialDocumentBodyComReqDto_1.getOfficialDocumentId(),"D3修改公文-D3-9修改公文主体(公共)-公文ID不能为空",false);
      updateOfficialDocumentBodyComRespDto_1 = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto_1)/*vcase invoke 同服务,同domain*/;



      }
if((reqDto!= null&&  reqDto.getBusAppDocRelaList() !=null && reqDto.getBusAppDocRelaList().size()>0)) {
        //if(D3修改公文.业务应用文档关系列表数据集条数 大于 0)  53638

ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto_1 = null;
    ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto_1=new ImplementSeparateAddOrDeleteDocListComReqDto();
  implementSeparateAddOrDeleteDocListComReqDto_1.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934780_1_69763
  implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseSceneCode("WORK_TASKS");//sourceId:1856887_1_69763
implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1856888_1_69763
implementSeparateAddOrDeleteDocListComReqDto_1.setIsResult("FALSE");//sourceId:1859370_1_69763
implementSeparateAddOrDeleteDocListComReqDto_1.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1856890_1_69763
implementSeparateAddOrDeleteDocListComReqDto_1.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1856896_1_69763
implementSeparateAddOrDeleteDocListComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1856885_1_69763
if(reqDto!= null&&  reqDto.getBusAppDocRelaList() !=null&& !CollectionUtil.isEmpty(reqDto.getBusAppDocRelaList())){
      implementSeparateAddOrDeleteDocListComReqDto_1.setDocumentList(reqDto.getBusAppDocRelaList().stream().map(item -> BeanUtil.toBean(item, com.wicket.okrcomponent.integration.dto.DocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1856886_1_69763
    }
if(reqDto!=null){
      implementSeparateAddOrDeleteDocListComReqDto_1.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1856884_1_69763
    }

    /*D2新增或删除公文附件文档列表(公共)[8783]   */
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsCleanPersonalInvalidDocument(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-是否清理个人无效文档不能为空",false);
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseSceneCode(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-文档应用业务场景不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseType(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-文档用途类型不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsResult(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-冗余是否结果文档不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnEntityId(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-归属内容表主键ID不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnTableTypeCode(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-归属内容表类型编码不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getUserId(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-归属个人账号不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getSpaceId(),"D3修改公文-D2新增或删除公文附件文档列表(公共)-创建于空间ID不能为空",false);
      implementSeparateAddOrDeleteDocListComRespDto_1 = fwCompUnstructuredDataClient.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;



ImplementDataAppointFormatShiftTextComRespDto implementDataAppointFormatShiftTextComRespDto = null;
          ImplementDataAppointFormatShiftTextComReqDto implementDataAppointFormatShiftTextComReqDto=new ImplementDataAppointFormatShiftTextComReqDto();
  implementDataAppointFormatShiftTextComReqDto.setCustomField1("；");//CUSTOM_CONVENTION//sourceId:1317426_1_53784
if(reqDto!= null&&  reqDto.getBusAppDocRelaList() !=null&& !CollectionUtil.isEmpty(reqDto.getBusAppDocRelaList())){
      implementDataAppointFormatShiftTextComReqDto.setDataAppointFormatShiftTextList(reqDto.getBusAppDocRelaList().stream().map(item->item.getFileRelativePathAccess())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1317425_1_53784
    }

    /*D2附件相对路径数据集转单字段[7515]   */
    Assert.isNull(implementDataAppointFormatShiftTextComReqDto.getCustomField1(),"D3修改公文-D2附件相对路径数据集转单字段-自定义字段1不能为空",false);
      implementDataAppointFormatShiftTextComRespDto = fwCompInterfaceModeClient.implementDataAppointFormatShiftTextCom(implementDataAppointFormatShiftTextComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto_2 = null;
    if(implementDataAppointFormatShiftTextComRespDto !=null){
          UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto_2=new UpdateOfficialDocumentBodyComReqDto();
  if(reqDto!=null){
      updateOfficialDocumentBodyComReqDto_2.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311574_1_53785
    }
if(implementDataAppointFormatShiftTextComRespDto!=null){
      updateOfficialDocumentBodyComReqDto_2.setAnnexAddress(implementDataAppointFormatShiftTextComRespDto.getCustomText());//SimpleFieldAssign//sourceId:1385547_1_53785
    }

    /*D3-9修改公文主体(公共)[7923]   */
    Assert.isNull(updateOfficialDocumentBodyComReqDto_2.getOfficialDocumentId(),"D3修改公文-D3-9修改公文主体(公共)-公文ID不能为空",false);
      updateOfficialDocumentBodyComRespDto_2 = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto_2)/*vcase invoke 同服务,同domain*/;



           }
      }
if((reqDto!= null&&  reqDto.getSubjectLifeCycle() !=null && reqDto.getSubjectLifeCycle().equals("CURRENTLY_VALID"))) {
        //if(D3修改公文.主体生命周期 等于 当前有效)  53523
        
QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
    QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto=new QueryOfficialDocumentDetailComReqDto();
  queryOfficialDocumentDetailComReqDto.setIsArchive("FALSE");//sourceId:1311742_1_53524
queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1311710_1_53524
if(reqDto!=null){
      queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311704_1_53524
    }
  
    /*D3-9查询公文详情(公共)[7930]   */
    Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(),"D3修改公文-D3-9查询公文详情(公共)-公文ID不能为空",false);
Assert.isNull(queryOfficialDocumentDetailComReqDto.getIsArchive(),"D3修改公文-D3-9查询公文详情(公共)-是否存档不能为空",false);
Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(),"D3修改公文-D3-9查询公文详情(公共)-创建于空间ID不能为空",false);
      queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      
ImplementNotificationTypeMsgTempanAlyzeComRespDto implementNotificationTypeMsgTempanAlyzeComRespDto = null;
    if(queryOfficialDocumentDetailComRespDto !=null){
          ImplementNotificationTypeMsgTempanAlyzeComReqDto implementNotificationTypeMsgTempanAlyzeComReqDto=new ImplementNotificationTypeMsgTempanAlyzeComReqDto();
  if(queryOfficialDocumentDetailComRespDto!=null){
      implementNotificationTypeMsgTempanAlyzeComReqDto.setNotificationType(queryOfficialDocumentDetailComRespDto.getNotificationType());//SimpleFieldAssign//sourceId:1418224_1_56691
implementNotificationTypeMsgTempanAlyzeComReqDto.setReceiveRange(queryOfficialDocumentDetailComRespDto.getReceiveRange());//SimpleFieldAssign//sourceId:1418225_1_56691
    }

    /*D3执行通知类型消息模板分析(公共)[8153]   */
    Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getNotificationType(),"D3修改公文-D3执行通知类型消息模板分析(公共)-通知类型不能为空",false);
Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getReceiveRange(),"D3修改公文-D3执行通知类型消息模板分析(公共)-接收范围不能为空",false);
      implementNotificationTypeMsgTempanAlyzeComRespDto = implementNotificationTypeMsgTempanAlyzeCom(implementNotificationTypeMsgTempanAlyzeComReqDto)/*vcase invoke 同服务,同domain*/;



           }
if((queryOfficialDocumentDetailComRespDto!= null&&  queryOfficialDocumentDetailComRespDto.getReceiveRange() !=null && queryOfficialDocumentDetailComRespDto.getReceiveRange().equals("EVERYONE"))) {
        //if(D3-9查询公文详情(公共).接收范围 等于 所有人)  54074

ImplementIssueOfficialDoSendOrgMemberMsgComRespDto implementIssueOfficialDoSendOrgMemberMsgComRespDto = null;
    if(queryOfficialDocumentDetailComRespDto !=null&&implementNotificationTypeMsgTempanAlyzeComRespDto !=null){
          ImplementIssueOfficialDoSendOrgMemberMsgComReqDto implementIssueOfficialDoSendOrgMemberMsgComReqDto=new ImplementIssueOfficialDoSendOrgMemberMsgComReqDto();
  implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331860_1_54168
  if(reqDto!=null){
      implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328780_1_54168
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331861_1_54168
    }
if(queryOfficialDocumentDetailComRespDto!=null){
      implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328781_1_54168
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageImportantLevel(queryOfficialDocumentDetailComRespDto.getRemindLevel());//SimpleFieldAssign//sourceId:1328801_1_54168
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331862_1_54168
    }
if(implementNotificationTypeMsgTempanAlyzeComRespDto!=null){
      implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1465841_1_54168
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464895_1_54168
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1465842_1_54168
    }

    /*D3执行下发公文给组织成员发消息(公共)[7968]   */
    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentId(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-公文ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentName(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-公文名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageImportantLevel(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentTypeCode(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentId(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-协同内容ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSurfaceContName(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-协同内容名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSendMsgScene(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-发送消息场景不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageTemplateCode(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-消息模板标识不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3修改公文-D3执行下发公文给组织成员发消息(公共)-消息标题模板引擎标识不能为空",false);
      implementIssueOfficialDoSendOrgMemberMsgComRespDto = messageService.implementIssueOfficialDoSendOrgMemberMsgCom(implementIssueOfficialDoSendOrgMemberMsgComReqDto)/*vcase invoke isSameApp*/;



           }
      }
else if((queryOfficialDocumentDetailComRespDto!= null&&  queryOfficialDocumentDetailComRespDto.getReceiveRange() !=null && queryOfficialDocumentDetailComRespDto.getReceiveRange().equals("DEPT")&&reqDto!= null&&  reqDto.getDeptList() !=null && reqDto.getDeptList().size()>0)){
       //elseif((D3-9查询公文详情(公共).接收范围 等于 部门 and D3修改公文.部门列表数据集条数 大于 0))  54075

ImplementIssueOfficialDoSendDeptMemberMsgComRespDto implementIssueOfficialDoSendDeptMemberMsgComRespDto = null;
    if(queryOfficialDocumentDetailComRespDto !=null&&implementNotificationTypeMsgTempanAlyzeComRespDto !=null){
          ImplementIssueOfficialDoSendDeptMemberMsgComReqDto implementIssueOfficialDoSendDeptMemberMsgComReqDto=new ImplementIssueOfficialDoSendDeptMemberMsgComReqDto();
  implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331848_1_54169
  if(reqDto!= null&&  reqDto.getDeptList() !=null&& !CollectionUtil.isEmpty(reqDto.getDeptList())){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setDeptList(reqDto.getDeptList().stream().map(item -> BeanUtil.toBean(item, DeptDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1328782_1_54169
    }
if(reqDto!=null){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328783_1_54169
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331849_1_54169
    }
if(queryOfficialDocumentDetailComRespDto!=null){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328784_1_54169
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageImportantLevel(queryOfficialDocumentDetailComRespDto.getRemindLevel());//SimpleFieldAssign//sourceId:1328802_1_54169
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331850_1_54169
    }
if(implementNotificationTypeMsgTempanAlyzeComRespDto!=null){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1464892_1_54169
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464893_1_54169
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464894_1_54169
    }

    /*D3执行下发公文给部门成员发消息(公共)[7969]   */
    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentId(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-公文ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentName(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-公文名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageImportantLevel(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentTypeCode(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentId(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-协同内容ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSurfaceContName(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-协同内容名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSendMsgScene(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-发送消息场景不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageTemplateCode(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-消息模板标识不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3修改公文-D3执行下发公文给部门成员发消息(公共)-消息标题模板引擎标识不能为空",false);
      implementIssueOfficialDoSendDeptMemberMsgComRespDto = messageService.implementIssueOfficialDoSendDeptMemberMsgCom(implementIssueOfficialDoSendDeptMemberMsgComReqDto)/*vcase invoke isSameApp*/;



           }
    }
else if((queryOfficialDocumentDetailComRespDto!= null&&  queryOfficialDocumentDetailComRespDto.getReceiveRange() !=null && queryOfficialDocumentDetailComRespDto.getReceiveRange().equals("PERSON")&&reqDto!= null&&  reqDto.getOrgInductionRecordList() !=null && reqDto.getOrgInductionRecordList().size()>0)){
       //elseif((D3-9查询公文详情(公共).接收范围 等于 个人 and D3修改公文.就职记录列表数据集条数 大于 0))  54167

ImplementLoopSinglePersonSendMsgComRespDto implementLoopSinglePersonSendMsgComRespDto = null;
    if(queryOfficialDocumentDetailComRespDto !=null&&implementNotificationTypeMsgTempanAlyzeComRespDto !=null){
          ImplementLoopSinglePersonSendMsgComReqDto implementLoopSinglePersonSendMsgComReqDto=new ImplementLoopSinglePersonSendMsgComReqDto();
  implementLoopSinglePersonSendMsgComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381958_1_55913
implementLoopSinglePersonSendMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381965_1_55913
if(reqDto!=null){
      implementLoopSinglePersonSendMsgComReqDto.setOrgInductionRecordList(reqDto.getOrgInductionRecordList());//list-field-assign//sourceId:1381957_1_55913
implementLoopSinglePersonSendMsgComReqDto.setEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381959_1_55913
implementLoopSinglePersonSendMsgComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381966_1_55913
    }
if(queryOfficialDocumentDetailComRespDto!=null){
      implementLoopSinglePersonSendMsgComReqDto.setObjectName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381961_1_55913
implementLoopSinglePersonSendMsgComReqDto.setMessageImportantLevel(queryOfficialDocumentDetailComRespDto.getRemindLevel());//SimpleFieldAssign//sourceId:1381962_1_55913
implementLoopSinglePersonSendMsgComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381967_1_55913
    }
if(implementNotificationTypeMsgTempanAlyzeComRespDto!=null){
      implementLoopSinglePersonSendMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1477095_1_55913
implementLoopSinglePersonSendMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1477090_1_55913
implementLoopSinglePersonSendMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1477091_1_55913
    }

    /*D3执行循环单人发消息(公共)[8086]   */
    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getTableTypeCode(),"D3修改公文-D3执行循环单人发消息(公共)-内容表类型编码不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getEntityId(),"D3修改公文-D3执行循环单人发消息(公共)-内容表主键ID不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getObjectName(),"D3修改公文-D3执行循环单人发消息(公共)-对象名称不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageImportantLevel(),"D3修改公文-D3执行循环单人发消息(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentTypeCode(),"D3修改公文-D3执行循环单人发消息(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentId(),"D3修改公文-D3执行循环单人发消息(公共)-协同内容ID不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSurfaceContName(),"D3修改公文-D3执行循环单人发消息(公共)-协同内容名称不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3修改公文-D3执行循环单人发消息(公共)-消息标题模板引擎标识不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageTemplateCode(),"D3修改公文-D3执行循环单人发消息(公共)-消息模板标识不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSendMsgScene(),"D3修改公文-D3执行循环单人发消息(公共)-发送消息场景不能为空",false);
      implementLoopSinglePersonSendMsgComRespDto = messageService.implementLoopSinglePersonSendMsgCom(implementLoopSinglePersonSendMsgComReqDto)/*vcase invoke isSameApp*/;



           }
    }
if((queryOfficialDocumentDetailComRespDto!= null&&  queryOfficialDocumentDetailComRespDto.getIsOpenWorkTask() !=null && queryOfficialDocumentDetailComRespDto.getIsOpenWorkTask().equals("TRUE")&&queryOfficialDocumentDetailComRespDto!= null&& queryOfficialDocumentDetailComRespDto.getAppointWorkTaskArrangeInductionId() != null )) {
        //if((D3-9查询公文详情(公共).是否开启工作任务 等于 是 and D3-9查询公文详情(公共).指定工作任务安排人就职记录ID 值不等于空 ))  54077

QueryInductionDeptDetailComRespDto queryInductionDeptDetailComRespDto = null;
    QueryInductionDeptDetailComReqDto queryInductionDeptDetailComReqDto=new QueryInductionDeptDetailComReqDto();
  queryInductionDeptDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477189_1_59125
if(reqDto!=null){
      queryInductionDeptDetailComReqDto.setInductionRecordId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1477188_1_59125
    }

    /*D1查工作任务安排人身份人员ID[7829]   */
    Assert.isNull(queryInductionDeptDetailComReqDto.getInductionRecordId(),"D3修改公文-D1查工作任务安排人身份人员ID-就职记录ID不能为空",false);
Assert.isNull(queryInductionDeptDetailComReqDto.getSpaceId(),"D3修改公文-D1查工作任务安排人身份人员ID-创建于空间ID不能为空",false);
      queryInductionDeptDetailComRespDto = fwBaseInductionRecordClient.queryInductionDeptDetailCom(queryInductionDeptDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



ImplementSendTwoPersonConvMsgAndNumComRespDto implementSendTwoPersonConvMsgAndNumComRespDto = null;
    if(queryInductionDeptDetailComRespDto !=null&&queryOfficialDocumentDetailComRespDto !=null){
          ImplementSendTwoPersonConvMsgAndNumComReqDto implementSendTwoPersonConvMsgAndNumComReqDto=new ImplementSendTwoPersonConvMsgAndNumComReqDto();
  implementSendTwoPersonConvMsgAndNumComReqDto.setSendMsgScene("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE");//sourceId:1477147_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477169_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477157_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477159_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setIsHandle("FALSE");//sourceId:1477167_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setHandleType("NEED_BUSINESS_OPERATION_HANDLING");//sourceId:1477168_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setPlatformReplace("FALSE");//sourceId:1477171_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setMessageImportantLevel(Long.valueOf(4));//CUSTOM_CONVENTION//sourceId:1477163_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setMsgTitleTemplateSemanticEngineCode("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1477151_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldName("objectName");//CUSTOM_CONVENTION//sourceId:1477152_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setComNumField(Long.valueOf(2));//CUSTOM_CONVENTION//sourceId:1477164_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477149_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1477150_1_59124
if(queryInductionDeptDetailComRespDto!=null){
      implementSendTwoPersonConvMsgAndNumComReqDto.setReceiveOriginalRoleMemberId(queryInductionDeptDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1477146_1_59124
    }
if(reqDto!=null){
      implementSendTwoPersonConvMsgAndNumComReqDto.setEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477170_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setTableContentEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1547110_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477160_1_59124
    }
if(queryOfficialDocumentDetailComRespDto!=null){
      implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477161_1_59124
implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldValue(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477153_1_59124
    }

    /*D3执行发两人会话消息及数量(公共)[8262]   */
    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSendMsgScene(),"D3修改公文-D3执行发两人会话消息及数量(公共)-发送消息场景不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getReceiveOriginalRoleMemberId(),"D3修改公文-D3执行发两人会话消息及数量(公共)-接收方身份人员ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceCode(),"D3修改公文-D3执行发两人会话消息及数量(公共)-归属内容类型编码不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getEntityId(),"D3修改公文-D3执行发两人会话消息及数量(公共)-归属内容ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableTypeCode(),"D3修改公文-D3执行发两人会话消息及数量(公共)-冗余内容表类型编码不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableContentEntityId(),"D3修改公文-D3执行发两人会话消息及数量(公共)-冗余内容表主键ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentTypeCode(),"D3修改公文-D3执行发两人会话消息及数量(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentId(),"D3修改公文-D3执行发两人会话消息及数量(公共)-协同内容ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceContName(),"D3修改公文-D3执行发两人会话消息及数量(公共)-协同内容名称不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getIsHandle(),"D3修改公文-D3执行发两人会话消息及数量(公共)-是否已处理不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getHandleType(),"D3修改公文-D3执行发两人会话消息及数量(公共)-处理类型不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getPlatformReplace(),"D3修改公文-D3执行发两人会话消息及数量(公共)-是否平台代操作不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageImportantLevel(),"D3修改公文-D3执行发两人会话消息及数量(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3修改公文-D3执行发两人会话消息及数量(公共)-消息标题模板引擎标识不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageTemplateCode(),"D3修改公文-D3执行发两人会话消息及数量(公共)-消息模板标识不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldName(),"D3修改公文-D3执行发两人会话消息及数量(公共)-第一个字段字段名不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldValue(),"D3修改公文-D3执行发两人会话消息及数量(公共)-第一个字段字段值不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getComNumField(),"D3修改公文-D3执行发两人会话消息及数量(公共)-通用数值字段（整数型）不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSpaceId(),"D3修改公文-D3执行发两人会话消息及数量(公共)-创建于空间ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getAppId(),"D3修改公文-D3执行发两人会话消息及数量(公共)-创建于联盟应用ID不能为空",false);
      implementSendTwoPersonConvMsgAndNumComRespDto = messageService.implementSendTwoPersonConvMsgAndNumCom(implementSendTwoPersonConvMsgAndNumComReqDto)/*vcase invoke isSameApp*/;



           }
      }
      }
//virtualUsage D2查平台文件存储根路径配置答案（公共）  71632
      QueryConfItemMatchAnswerDetailComRespDto queryConfItemMatchAnswerDetailComRespDto = null;
    QueryConfItemMatchAnswerDetailComReqDto queryConfItemMatchAnswerDetailComReqDto=new QueryConfItemMatchAnswerDetailComReqDto();
  queryConfItemMatchAnswerDetailComReqDto.setConfItemCode("FILE_STORAGE_ROOT_PATH");//CUSTOM_CONVENTION//sourceId:1935923_1_71632
queryConfItemMatchAnswerDetailComReqDto.setConfSchemeCode("COM_CONF_SCHEME");//CUSTOM_CONVENTION//sourceId:1935924_1_71632
queryConfItemMatchAnswerDetailComReqDto.setIsPlatData("TRUE");//sourceId:1935925_1_71632

    /*D2查平台文件存储根路径配置答案（公共）[2486]   */
    Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfItemCode(),"D3修改公文-D2查平台文件存储根路径配置答案（公共）-配置项标识不能为空",false);
Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfSchemeCode(),"D3修改公文-D2查平台文件存储根路径配置答案（公共）-配置方案标识不能为空",false);
Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getIsPlatData(),"D3修改公文-D2查平台文件存储根路径配置答案（公共）-是否标准答案不能为空",false);
      queryConfItemMatchAnswerDetailComRespDto = fwCompConfSchemeClient.queryConfItemMatchAnswerDetailCom(queryConfItemMatchAnswerDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



//virtualUsage D2执行清理个人用户无效文件(公共)  71633
      ImplementClearMemberInvalidDocComRespDto implementClearMemberInvalidDocComRespDto = null;
    if(queryConfItemMatchAnswerDetailComRespDto !=null){
          ImplementClearMemberInvalidDocComReqDto implementClearMemberInvalidDocComReqDto=new ImplementClearMemberInvalidDocComReqDto();
  implementClearMemberInvalidDocComReqDto.setIsCleanPersonalInvalidDocument("TRUE");//sourceId:1935186_1_71633
implementClearMemberInvalidDocComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1935184_1_71633
if(queryConfItemMatchAnswerDetailComRespDto!=null){
      implementClearMemberInvalidDocComReqDto.setFileStorageRootPath(queryConfItemMatchAnswerDetailComRespDto.getEndValue());//SimpleFieldAssign//sourceId:1935185_1_71633
    }

    /*D2执行清理个人用户无效文件(公共)[8792]   */
    Assert.isNull(implementClearMemberInvalidDocComReqDto.getIsCleanPersonalInvalidDocument(),"D3修改公文-D2执行清理个人用户无效文件(公共)-是否清理个人无效文档不能为空",false);
Assert.isNull(implementClearMemberInvalidDocComReqDto.getUserId(),"D3修改公文-D2执行清理个人用户无效文件(公共)-归属个人账号不能为空",false);
Assert.isNull(implementClearMemberInvalidDocComReqDto.getFileStorageRootPath(),"D3修改公文-D2执行清理个人用户无效文件(公共)-文件存储根路径不能为空",false);
      implementClearMemberInvalidDocComRespDto = fwCompUnstructuredDataClient.implementClearMemberInvalidDocCom(implementClearMemberInvalidDocComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



      }
UpdateOfficialDocumentRespDto retData = new UpdateOfficialDocumentRespDto();
  
  

  
  
return retData;
  }
/**
   * D3-9删除公文(公共)[7939]
   * gen by moon at 11/12/2023, 10:33:39 PM
   */
  @Trace(operationName = "D3-9删除公文(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public DeleteOfficialDocumentComRespDto deleteOfficialDocumentCom(DeleteOfficialDocumentComReqDto reqDto){
    
      
      //步骤0: 3-9-01删除公文 - deleteOfficialDocument
     boolean bOOLEAN ;
    String string=new String();
  if(reqDto!=null){
      string=reqDto.getOfficialDocumentId();;//SimpleFieldAssign//sourceId:1312452_1
    }
  
    /*3-9-01删除公文[7940]   */
    Assert.isNull(string,"D3-9删除公文(公共)-3-9-01删除公文-公文ID不能为空",false);
      bOOLEAN = mOmsOfficialDocumentService.deleteOfficialDocument(string)/*vcase invoke 本地 method 方法调用;*/;
      
      
      
    
DeleteOfficialDocumentComRespDto retData = new DeleteOfficialDocumentComRespDto();
  
  

  
  
return retData;
  }
/**
   * D3-9查询公文详情(公共)[7930]
   * gen by moon at 12/16/2023, 8:36:54 PM
   */
  @Trace(operationName = "D3-9查询公文详情(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailCom(QueryOfficialDocumentDetailComReqDto reqDto){
    
      
      OmsOfficialDocument omsOfficialDocument_1 =null;
//步骤0: 3-9-01查询公文详情 - queryOfficialDocumentDetail
     OmsOfficialDocument omsOfficialDocument = null;
    QueryOfficialDocumentDetailReq queryOfficialDocumentDetailReq=new QueryOfficialDocumentDetailReq();
  if(reqDto!=null){
      queryOfficialDocumentDetailReq.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311634_1
queryOfficialDocumentDetailReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311635_1
queryOfficialDocumentDetailReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311636_1
queryOfficialDocumentDetailReq.setReceiveInductionId(reqDto.getReceiveInductionId());//SimpleFieldAssign//sourceId:1311637_1
queryOfficialDocumentDetailReq.setArrangeWorkTaskId(reqDto.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1345986_1
queryOfficialDocumentDetailReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1311641_1
queryOfficialDocumentDetailReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311642_1
queryOfficialDocumentDetailReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1311638_1
    }
  
    /*3-9-01查询公文详情[7929]   */
    Assert.isNull(queryOfficialDocumentDetailReq.getSpaceId(),"D3-9查询公文详情(公共)-3-9-01查询公文详情-创建于空间ID不能为空",false);
      omsOfficialDocument = mOmsOfficialDocumentService.queryOfficialDocumentDetail(queryOfficialDocumentDetailReq)/*vcase invoke 本地 method 方法调用;*/;
      
      
      omsOfficialDocument_1 = omsOfficialDocument;
    
QueryOfficialDocumentDetailComRespDto retData = new QueryOfficialDocumentDetailComRespDto();
  if(omsOfficialDocument_1!=null){
      retData.setOfficialDocumentId(omsOfficialDocument_1.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311673_1
retData.setOfficialDocumentName(omsOfficialDocument_1.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311674_1
retData.setOfficialDocumentNum(omsOfficialDocument_1.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311675_1
retData.setNotificationDescription(omsOfficialDocument_1.getNotificationDescription());//SimpleFieldAssign//sourceId:1420042_1
retData.setOfficialDocumentFileAddress(omsOfficialDocument_1.getOfficialDocumentFileAddress());//SimpleFieldAssign//sourceId:1311676_1
retData.setAnnexAddress(omsOfficialDocument_1.getAnnexAddress());//SimpleFieldAssign//sourceId:1311677_1
retData.setReceiveRange(omsOfficialDocument_1.getReceiveRange());//SimpleFieldAssign//sourceId:1311678_1
retData.setNotificationType(omsOfficialDocument_1.getNotificationType());//SimpleFieldAssign//sourceId:1418231_1
retData.setReceiveInductionId(omsOfficialDocument_1.getReceiveInductionId());//SimpleFieldAssign//sourceId:1311679_1
retData.setRemindLevel(omsOfficialDocument_1.getRemindLevel());//SimpleFieldAssign//sourceId:1311680_1
retData.setIsOpenWorkTask(omsOfficialDocument_1.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311681_1
retData.setWorkTaskIsArrange(omsOfficialDocument_1.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1311682_1
retData.setAppointWorkTaskArrangeInductionId(omsOfficialDocument_1.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311683_1
retData.setArrangeWorkTaskId(omsOfficialDocument_1.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1317445_1
retData.setArrangeWorkTaskTypeCode(omsOfficialDocument_1.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1317446_1
retData.setSubjectLifeCycle(omsOfficialDocument_1.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311684_1
retData.setIsArchive(omsOfficialDocument_1.getIsArchive());//SimpleFieldAssign//sourceId:1311685_1
retData.setOperationInductionId(omsOfficialDocument_1.getOperationInductionId());//SimpleFieldAssign//sourceId:1311686_1
retData.setCreateInductionId(omsOfficialDocument_1.getCreateInductionId());//SimpleFieldAssign//sourceId:1311687_1
retData.setReleaseInductionId(omsOfficialDocument_1.getReleaseInductionId());//SimpleFieldAssign//sourceId:1311688_1
retData.setArchiveInductionId(omsOfficialDocument_1.getArchiveInductionId());//SimpleFieldAssign//sourceId:1311689_1
retData.setOperateTime(omsOfficialDocument_1.getOperateTime());//SimpleFieldAssign//sourceId:1311690_1
retData.setCreateTime(omsOfficialDocument_1.getCreateTime());//SimpleFieldAssign//sourceId:1311691_1
retData.setReleaseTime(omsOfficialDocument_1.getReleaseTime());//SimpleFieldAssign//sourceId:1311692_1
retData.setArchiveTime(omsOfficialDocument_1.getArchiveTime());//SimpleFieldAssign//sourceId:1311693_1
retData.setSpaceId(omsOfficialDocument_1.getSpaceId());//SimpleFieldAssign//sourceId:1311694_1
retData.setAppId(omsOfficialDocument_1.getAppId());//SimpleFieldAssign//sourceId:1311695_1
    }
  

  
  
return retData;
  }
/**
   * D3-9查询相同公文列表(公共)[7925]
   * gen by moon at 12/16/2023, 1:44:33 PM
   */
  @Trace(operationName = "D3-9查询相同公文列表(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryAlikeOfficialDocumentListComRespDto queryAlikeOfficialDocumentListCom(QueryAlikeOfficialDocumentListComReqDto reqDto){
    
      
      List<OmsOfficialDocument> listOmsOfficialDocument_1 =new ArrayList<>();
//步骤0: 3-9-01查询公文列表 - queryOfficialDocumentList
     List<OmsOfficialDocument> listOmsOfficialDocument =new ArrayList<>();
    QueryOfficialDocumentListReq queryOfficialDocumentListReq=new QueryOfficialDocumentListReq();
  if(reqDto!=null){
      queryOfficialDocumentListReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311546_1
queryOfficialDocumentListReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311551_1
queryOfficialDocumentListReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416396_1
queryOfficialDocumentListReq.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420004_1
queryOfficialDocumentListReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1311547_1
queryOfficialDocumentListReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311552_1
queryOfficialDocumentListReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1311548_1
    }
  
    /*3-9-01查询公文列表[7926]   */
    Assert.isNull(queryOfficialDocumentListReq.getSpaceId(),"D3-9查询相同公文列表(公共)-3-9-01查询公文列表-创建于空间ID不能为空",false);
      listOmsOfficialDocument = mOmsOfficialDocumentService.queryOfficialDocumentList(queryOfficialDocumentListReq)/*vcase invoke 本地 method 方法调用;*/;
      
      
      listOmsOfficialDocument_1 = listOmsOfficialDocument;
    
QueryAlikeOfficialDocumentListComRespDto retData = new QueryAlikeOfficialDocumentListComRespDto();
  retData.setOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, OfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1311558_1
  

  
  
return retData;
  }
/**
   * D3-9新增公文主体(公共)[7920]
   * gen by moon at 12/16/2023, 8:36:40 PM
   */
  @Trace(operationName = "D3-9新增公文主体(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public AddOfficialDocumentBodyComRespDto addOfficialDocumentBodyCom(AddOfficialDocumentBodyComReqDto reqDto){
    
      
      String string_1 =null;
//步骤0: 3-9-01新增公文 - addOfficialDocument
     String string = null;
    OmsOfficialDocument omsOfficialDocument=new OmsOfficialDocument();
  if(reqDto!=null){
      omsOfficialDocument.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311418_1
omsOfficialDocument.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311419_1
omsOfficialDocument.setNotificationDescription(reqDto.getNotificationDescription());//SimpleFieldAssign//sourceId:1420035_1
omsOfficialDocument.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1311422_1
omsOfficialDocument.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416387_1
omsOfficialDocument.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311424_1
omsOfficialDocument.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311425_1
omsOfficialDocument.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1311426_1
omsOfficialDocument.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311427_1
omsOfficialDocument.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420009_1
omsOfficialDocument.setIssueSubjectTypeCode(reqDto.getIssueSubjectTypeCode());//SimpleFieldAssign//sourceId:1420010_1
omsOfficialDocument.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311428_1
    }
  
    /*3-9-01新增公文[7919]   */
    Assert.isNull(omsOfficialDocument.getOfficialDocumentName(),"D3-9新增公文主体(公共)-3-9-01新增公文-公文名称不能为空",false);
Assert.isNull(omsOfficialDocument.getReceiveRange(),"D3-9新增公文主体(公共)-3-9-01新增公文-接收范围不能为空",false);
Assert.isNull(omsOfficialDocument.getNotificationType(),"D3-9新增公文主体(公共)-3-9-01新增公文-通知类型不能为空",false);
Assert.isNull(omsOfficialDocument.getIsOpenWorkTask(),"D3-9新增公文主体(公共)-3-9-01新增公文-是否开启工作任务不能为空",false);
Assert.isNull(omsOfficialDocument.getSubjectLifeCycle(),"D3-9新增公文主体(公共)-3-9-01新增公文-主体生命周期不能为空",false);
      string = mOmsOfficialDocumentService.addOfficialDocument(omsOfficialDocument)/*vcase invoke 本地 method 方法调用;*/;
      
      
      string_1 = string;
    
AddOfficialDocumentBodyComRespDto retData = new AddOfficialDocumentBodyComRespDto();
  if(string_1!=null){
      retData.setOfficialDocumentId(string_1);//SimpleFieldAssign//sourceId:1311441_1
    }
  

  
  
return retData;
  }
/**
   * D3新增公文[7921]
   * gen by moon at 7/18/2024, 6:34:29 PM
   */
  @Trace(operationName = "D3新增公文")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public AddOfficialDocumentRespDto addOfficialDocument(AddOfficialDocumentReqDto reqDto){
    
      
      AddOfficialDocumentBodyComRespDto addOfficialDocumentBodyComRespDto_1 =null;
//virtualUsage D3-9查询相同公文列表(公共)  53497
      QueryAlikeOfficialDocumentListComRespDto queryAlikeOfficialDocumentListComRespDto = null;
    QueryAlikeOfficialDocumentListComReqDto queryAlikeOfficialDocumentListComReqDto=new QueryAlikeOfficialDocumentListComReqDto();
  queryAlikeOfficialDocumentListComReqDto.setIsArchive("FALSE");//sourceId:1311565_1_53497
queryAlikeOfficialDocumentListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1311563_1_53497
if(reqDto!=null){
      queryAlikeOfficialDocumentListComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311559_1_53497
queryAlikeOfficialDocumentListComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416398_1_53497
queryAlikeOfficialDocumentListComReqDto.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420006_1_53497
    }
  
    /*D3-9查询相同公文列表(公共)[7925]   */
    Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getOfficialDocumentName(),"D3新增公文-D3-9查询相同公文列表(公共)-公文名称不能为空",false);
Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getNotificationType(),"D3新增公文-D3-9查询相同公文列表(公共)-通知类型不能为空",false);
Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getIsArchive(),"D3新增公文-D3-9查询相同公文列表(公共)-是否存档不能为空",false);
Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getSpaceId(),"D3新增公文-D3-9查询相同公文列表(公共)-创建于空间ID不能为空",false);
      queryAlikeOfficialDocumentListComRespDto = queryAlikeOfficialDocumentListCom(queryAlikeOfficialDocumentListComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      
if((queryAlikeOfficialDocumentListComRespDto!= null&&  queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList() !=null && queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList().size()>0)) {
        //if(D3-9查询相同公文列表(公共).公文列表数据集条数 大于 0)  53498
        
//异常结束 53499
      throw new BizException("C00116","对不起！已存在~！",false);
      }
else if((queryAlikeOfficialDocumentListComRespDto!= null&&  queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList() !=null && queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList().size()==0)){
       //elseif(D3-9查询相同公文列表(公共).公文列表数据集条数 等于 0)  53500
      
AddOfficialDocumentBodyComRespDto addOfficialDocumentBodyComRespDto = null;
    AddOfficialDocumentBodyComReqDto addOfficialDocumentBodyComReqDto=new AddOfficialDocumentBodyComReqDto();
  if(reqDto!=null){
      addOfficialDocumentBodyComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311442_1_53501
addOfficialDocumentBodyComReqDto.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311443_1_53501
addOfficialDocumentBodyComReqDto.setNotificationDescription(reqDto.getNotificationDescription());//SimpleFieldAssign//sourceId:1420037_1_53501
addOfficialDocumentBodyComReqDto.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1311446_1_53501
addOfficialDocumentBodyComReqDto.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311448_1_53501
addOfficialDocumentBodyComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416389_1_53501
addOfficialDocumentBodyComReqDto.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311449_1_53501
addOfficialDocumentBodyComReqDto.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311451_1_53501
addOfficialDocumentBodyComReqDto.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420013_1_53501
addOfficialDocumentBodyComReqDto.setIssueSubjectTypeCode(reqDto.getIssueSubjectTypeCode());//SimpleFieldAssign//sourceId:1420014_1_53501
addOfficialDocumentBodyComReqDto.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311452_1_53501
    }
  
    /*D3-9新增公文主体(公共)[7920]   */
    Assert.isNull(addOfficialDocumentBodyComReqDto.getOfficialDocumentName(),"D3新增公文-D3-9新增公文主体(公共)-公文名称不能为空",false);
Assert.isNull(addOfficialDocumentBodyComReqDto.getReceiveRange(),"D3新增公文-D3-9新增公文主体(公共)-接收范围不能为空",false);
Assert.isNull(addOfficialDocumentBodyComReqDto.getNotificationType(),"D3新增公文-D3-9新增公文主体(公共)-通知类型不能为空",false);
Assert.isNull(addOfficialDocumentBodyComReqDto.getIsOpenWorkTask(),"D3新增公文-D3-9新增公文主体(公共)-是否开启工作任务不能为空",false);
Assert.isNull(addOfficialDocumentBodyComReqDto.getSubjectLifeCycle(),"D3新增公文-D3-9新增公文主体(公共)-主体生命周期不能为空",false);
      addOfficialDocumentBodyComRespDto = addOfficialDocumentBodyCom(addOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      addOfficialDocumentBodyComRespDto_1 = addOfficialDocumentBodyComRespDto;
ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto = null;
    if(addOfficialDocumentBodyComRespDto !=null){
          ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto=new ImplementSeparateAddOrDeleteDocListComReqDto();
  implementSeparateAddOrDeleteDocListComReqDto.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934774_1_69745
  implementSeparateAddOrDeleteDocListComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1854864_1_69745
implementSeparateAddOrDeleteDocListComReqDto.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1854865_1_69745
implementSeparateAddOrDeleteDocListComReqDto.setIsResult("FALSE");//sourceId:1859364_1_69745
implementSeparateAddOrDeleteDocListComReqDto.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1854867_1_69745
implementSeparateAddOrDeleteDocListComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1854873_1_69745
implementSeparateAddOrDeleteDocListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1854862_1_69745
if(reqDto!= null&&  reqDto.getDocumentList() !=null&& !CollectionUtil.isEmpty(reqDto.getDocumentList())){
      implementSeparateAddOrDeleteDocListComReqDto.setDocumentList(reqDto.getDocumentList().stream().map(item -> BeanUtil.toBean(item, com.wicket.okrcomponent.integration.dto.DocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1854863_1_69745
    }
if(addOfficialDocumentBodyComRespDto!=null){
      implementSeparateAddOrDeleteDocListComReqDto.setOwnEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1854861_1_69745
    }

    /*D2新增或删除公文附件文档关系(公共)[8783]   */
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsCleanPersonalInvalidDocument(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-是否清理个人无效文档不能为空",false);
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseSceneCode(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-文档应用业务场景不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseType(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-文档用途类型不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsResult(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-冗余是否结果文档不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnEntityId(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-归属内容表主键ID不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnTableTypeCode(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-归属内容表类型编码不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getUserId(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-归属个人账号不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getSpaceId(),"D3新增公文-D2新增或删除公文附件文档关系(公共)-创建于空间ID不能为空",false);
      implementSeparateAddOrDeleteDocListComRespDto = fwCompUnstructuredDataClient.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }
ImplementDataAppointFormatShiftTextComRespDto implementDataAppointFormatShiftTextComRespDto = null;
          ImplementDataAppointFormatShiftTextComReqDto implementDataAppointFormatShiftTextComReqDto=new ImplementDataAppointFormatShiftTextComReqDto();
  implementDataAppointFormatShiftTextComReqDto.setCustomField1("；");//CUSTOM_CONVENTION//sourceId:1313461_1_53623
if(reqDto!= null&&  reqDto.getDocumentList() !=null&& !CollectionUtil.isEmpty(reqDto.getDocumentList())){
      implementDataAppointFormatShiftTextComReqDto.setDataAppointFormatShiftTextList(reqDto.getDocumentList().stream().map(item->item.getFileRelativePathAccess())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1313460_1_53623
    }

    /*D2附件相对路径数据集转单字段[7515]   */
    Assert.isNull(implementDataAppointFormatShiftTextComReqDto.getCustomField1(),"D3新增公文-D2附件相对路径数据集转单字段-自定义字段1不能为空",false);
      implementDataAppointFormatShiftTextComRespDto = fwCompInterfaceModeClient.implementDataAppointFormatShiftTextCom(implementDataAppointFormatShiftTextComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



if((reqDto!= null&& reqDto.getOfficialDocumentUnstructuredDataId() != null )) {
        //if(D3新增公文.公文文档ID 值不等于空 )  53616

ImplementSingleMultipleFieldSetDataEntryComRespDto implementSingleMultipleFieldSetDataEntryComRespDto = null;
    ImplementSingleMultipleFieldSetDataEntryComReqDto implementSingleMultipleFieldSetDataEntryComReqDto=new ImplementSingleMultipleFieldSetDataEntryComReqDto();
if(reqDto!=null){
      implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField1(reqDto.getOfficialDocumentUnstructuredDataId());//SimpleFieldAssign//sourceId:1856422_1_69759
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField2(reqDto.getPostfix());//SimpleFieldAssign//sourceId:1856423_1_69759
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField3(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1856424_1_69759
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField4(reqDto.getSourceRelationshipId());//SimpleFieldAssign//sourceId:1856425_1_69759
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField5(reqDto.getRelationshipType());//SimpleFieldAssign//sourceId:1856426_1_69759
implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField6(reqDto.getIsNetworkReference());//SimpleFieldAssign//sourceId:1856427_1_69759
    }

    /*D2执行单条多字段转数据集(公共)[9762]   */
    Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField1(),"D3新增公文-D2执行单条多字段转数据集(公共)-自定义字段1不能为空",false);
Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField2(),"D3新增公文-D2执行单条多字段转数据集(公共)-自定义字段2不能为空",false);
Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField3(),"D3新增公文-D2执行单条多字段转数据集(公共)-自定义字段3不能为空",false);
      implementSingleMultipleFieldSetDataEntryComRespDto = fwCompDataSetSingleEntryClient.implementSingleMultipleFieldSetDataEntryCom(implementSingleMultipleFieldSetDataEntryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto_1 = null;
    if(implementSingleMultipleFieldSetDataEntryComRespDto !=null&&addOfficialDocumentBodyComRespDto !=null){
          ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto_1=new ImplementSeparateAddOrDeleteDocListComReqDto();
  implementSeparateAddOrDeleteDocListComReqDto_1.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934775_1_69758
  implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseSceneCode("WORK_TASKS");//sourceId:1856051_1_69758
implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1856052_1_69758
implementSeparateAddOrDeleteDocListComReqDto_1.setIsResult("FALSE");//sourceId:1859365_1_69758
implementSeparateAddOrDeleteDocListComReqDto_1.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1856054_1_69758
implementSeparateAddOrDeleteDocListComReqDto_1.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1856060_1_69758
implementSeparateAddOrDeleteDocListComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1856049_1_69758
if(implementSingleMultipleFieldSetDataEntryComRespDto!= null&&  implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList() !=null&& !CollectionUtil.isEmpty(implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList())){
      implementSeparateAddOrDeleteDocListComReqDto_1.setDocumentList(//objList-to-objLists
        implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList().stream().map(item -> {
            com.wicket.okrcomponent.integration.dto.DocumentDto elm = new com.wicket.okrcomponent.integration.dto.DocumentDto();
      if(item!=null){
      elm.setUnstructuredDataId(item.getCustomField1());//SimpleFieldAssign//sourceId:371771_2_69758
elm.setPostfix(item.getCustomField2());//SimpleFieldAssign//sourceId:371775_2_69758
elm.setFileRelativePathAccess(item.getCustomField3());//SimpleFieldAssign//sourceId:371776_2_69758
elm.setSourceRelationshipId(item.getCustomField4());//SimpleFieldAssign//sourceId:371772_2_69758
elm.setRelationshipType(item.getCustomField5());//SimpleFieldAssign//sourceId:371773_2_69758
elm.setIsNetworkReference(item.getCustomField6());//SimpleFieldAssign//sourceId:371774_2_69758
    }
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1856050_1_69758
    }
if(addOfficialDocumentBodyComRespDto!=null){
      implementSeparateAddOrDeleteDocListComReqDto_1.setOwnEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1856048_1_69758
    }

    /*D2新增或删除公文主体文档关系(公共)[8783]   */
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsCleanPersonalInvalidDocument(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-是否清理个人无效文档不能为空",false);
    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseSceneCode(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-文档应用业务场景不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseType(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-文档用途类型不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsResult(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-冗余是否结果文档不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnEntityId(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-归属内容表主键ID不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnTableTypeCode(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-归属内容表类型编码不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getUserId(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-归属个人账号不能为空",false);
Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getSpaceId(),"D3新增公文-D2新增或删除公文主体文档关系(公共)-创建于空间ID不能为空",false);
      implementSeparateAddOrDeleteDocListComRespDto_1 = fwCompUnstructuredDataClient.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;



           }
UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto = null;
    if(addOfficialDocumentBodyComRespDto !=null&&implementDataAppointFormatShiftTextComRespDto !=null){
          UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto=new UpdateOfficialDocumentBodyComReqDto();
  if(addOfficialDocumentBodyComRespDto!=null){
      updateOfficialDocumentBodyComReqDto.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1313389_1_53618
    }
if(reqDto!=null){
      updateOfficialDocumentBodyComReqDto.setOfficialDocumentFileAddress(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1313391_1_53618
    }
if(implementDataAppointFormatShiftTextComRespDto!=null){
      updateOfficialDocumentBodyComReqDto.setAnnexAddress(implementDataAppointFormatShiftTextComRespDto.getCustomText());//SimpleFieldAssign//sourceId:1313463_1_53618
    }

    /*D3写入公文文件地址[7923]   */
    Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentId(),"D3新增公文-D3写入公文文件地址-公文ID不能为空",false);
Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentFileAddress(),"D3新增公文-D3写入公文文件地址-公文文件地址不能为空",false);
      updateOfficialDocumentBodyComRespDto = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;



           }
      }
if((reqDto!= null&&  reqDto.getIsOpenWorkTask() !=null && reqDto.getIsOpenWorkTask().equals("TRUE"))) {
        //if(D3新增公文.是否开启工作任务 等于 是)  53503
        
UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto_1 = null;
    if(addOfficialDocumentBodyComRespDto !=null){
          UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto_1=new UpdateOfficialDocumentBodyComReqDto();
  updateOfficialDocumentBodyComReqDto_1.setWorkTaskIsArrange("FALSE");//sourceId:1311510_1_53504
if(addOfficialDocumentBodyComRespDto!=null){
      updateOfficialDocumentBodyComReqDto_1.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311509_1_53504
    }
  
    /*D3修改公文工作任务是否已安排为否[7923]   */
    Assert.isNull(updateOfficialDocumentBodyComReqDto_1.getOfficialDocumentId(),"D3新增公文-D3修改公文工作任务是否已安排为否-公文ID不能为空",false);
Assert.isNull(updateOfficialDocumentBodyComReqDto_1.getWorkTaskIsArrange(),"D3新增公文-D3修改公文工作任务是否已安排为否-工作任务是否已安排不能为空",false);
      updateOfficialDocumentBodyComRespDto_1 = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto_1)/*vcase invoke 同服务,同domain*/;
      
      
      
           }
      }
if((reqDto!= null&&  reqDto.getSubjectLifeCycle() !=null && reqDto.getSubjectLifeCycle().equals("CURRENTLY_VALID"))) {
        //if(D3新增公文.主体生命周期 等于 当前有效)  54069

ImplementNotificationTypeMsgTempanAlyzeComRespDto implementNotificationTypeMsgTempanAlyzeComRespDto = null;
    ImplementNotificationTypeMsgTempanAlyzeComReqDto implementNotificationTypeMsgTempanAlyzeComReqDto=new ImplementNotificationTypeMsgTempanAlyzeComReqDto();
  if(reqDto!=null){
      implementNotificationTypeMsgTempanAlyzeComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418200_1_56690
implementNotificationTypeMsgTempanAlyzeComReqDto.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1418201_1_56690
    }

    /*D3执行通知类型消息模板分析(公共)[8153]   */
    Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getNotificationType(),"D3新增公文-D3执行通知类型消息模板分析(公共)-通知类型不能为空",false);
Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getReceiveRange(),"D3新增公文-D3执行通知类型消息模板分析(公共)-接收范围不能为空",false);
      implementNotificationTypeMsgTempanAlyzeComRespDto = implementNotificationTypeMsgTempanAlyzeCom(implementNotificationTypeMsgTempanAlyzeComReqDto)/*vcase invoke 同服务,同domain*/;



if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("EVERYONE"))) {
        //if(D3新增公文.接收范围 等于 所有人)  54072

ImplementIssueOfficialDoSendOrgMemberMsgComRespDto implementIssueOfficialDoSendOrgMemberMsgComRespDto = null;
    if(addOfficialDocumentBodyComRespDto !=null&&implementNotificationTypeMsgTempanAlyzeComRespDto !=null){
          ImplementIssueOfficialDoSendOrgMemberMsgComReqDto implementIssueOfficialDoSendOrgMemberMsgComReqDto=new ImplementIssueOfficialDoSendOrgMemberMsgComReqDto();
  implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331863_1_54160
  if(addOfficialDocumentBodyComRespDto!=null){
      implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328759_1_54160
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331864_1_54160
    }
if(reqDto!=null){
      implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328760_1_54160
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageImportantLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1328798_1_54160
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331865_1_54160
    }
if(implementNotificationTypeMsgTempanAlyzeComRespDto!=null){
      implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1465655_1_54160
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1465656_1_54160
implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1465657_1_54160
    }

    /*D3执行下发公文给组织成员发消息(公共)[7968]   */
    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentId(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-公文ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentName(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-公文名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageImportantLevel(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentTypeCode(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentId(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-协同内容ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSurfaceContName(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-协同内容名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSendMsgScene(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-发送消息场景不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageTemplateCode(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-消息模板标识不能为空",false);
Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3新增公文-D3执行下发公文给组织成员发消息(公共)-消息标题模板引擎标识不能为空",false);
      implementIssueOfficialDoSendOrgMemberMsgComRespDto = messageService.implementIssueOfficialDoSendOrgMemberMsgCom(implementIssueOfficialDoSendOrgMemberMsgComReqDto)/*vcase invoke isSameApp*/;



           }
      }
else if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("DEPT")&&reqDto!= null&&  reqDto.getDeptList() !=null && reqDto.getDeptList().size()>0)){
       //elseif((D3新增公文.接收范围 等于 部门 and D3新增公文.部门列表数据集条数 大于 0))  54073

ImplementIssueOfficialDoSendDeptMemberMsgComRespDto implementIssueOfficialDoSendDeptMemberMsgComRespDto = null;
    if(addOfficialDocumentBodyComRespDto !=null&&implementNotificationTypeMsgTempanAlyzeComRespDto !=null){
          ImplementIssueOfficialDoSendDeptMemberMsgComReqDto implementIssueOfficialDoSendDeptMemberMsgComReqDto=new ImplementIssueOfficialDoSendDeptMemberMsgComReqDto();
  implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331866_1_54161
  if(reqDto!= null&&  reqDto.getDeptList() !=null&& !CollectionUtil.isEmpty(reqDto.getDeptList())){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setDeptList(reqDto.getDeptList().stream().map(item -> BeanUtil.toBean(item, DeptDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1328756_1_54161
    }
if(addOfficialDocumentBodyComRespDto!=null){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328757_1_54161
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331867_1_54161
    }
if(reqDto!=null){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328758_1_54161
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331868_1_54161
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageImportantLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1331869_1_54161
    }
if(implementNotificationTypeMsgTempanAlyzeComRespDto!=null){
      implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1465237_1_54161
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1465238_1_54161
implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1465239_1_54161
    }

    /*D3执行下发公文给部门成员发消息(公共)[7969]   */
    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentId(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-公文ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentName(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-公文名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentTypeCode(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentId(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-协同内容ID不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSurfaceContName(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-协同内容名称不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageImportantLevel(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSendMsgScene(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-发送消息场景不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageTemplateCode(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-消息模板标识不能为空",false);
Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3新增公文-D3执行下发公文给部门成员发消息(公共)-消息标题模板引擎标识不能为空",false);
      implementIssueOfficialDoSendDeptMemberMsgComRespDto = messageService.implementIssueOfficialDoSendDeptMemberMsgCom(implementIssueOfficialDoSendDeptMemberMsgComReqDto)/*vcase invoke isSameApp*/;



           }
    }
else if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("PERSON")&&reqDto!= null&&  reqDto.getOrgInductionRecordList() !=null && reqDto.getOrgInductionRecordList().size()>0)){
       //elseif((D3新增公文.接收范围 等于 个人 and D3新增公文.就职记录列表数据集条数 大于 0))  54159

ImplementLoopSinglePersonSendMsgComRespDto implementLoopSinglePersonSendMsgComRespDto = null;
    if(addOfficialDocumentBodyComRespDto !=null&&implementNotificationTypeMsgTempanAlyzeComRespDto !=null){
          ImplementLoopSinglePersonSendMsgComReqDto implementLoopSinglePersonSendMsgComReqDto=new ImplementLoopSinglePersonSendMsgComReqDto();
  implementLoopSinglePersonSendMsgComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381942_1_55912
implementLoopSinglePersonSendMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381950_1_55912
if(reqDto!=null){
      implementLoopSinglePersonSendMsgComReqDto.setOrgInductionRecordList(reqDto.getOrgInductionRecordList());//list-field-assign//sourceId:1381941_1_55912
implementLoopSinglePersonSendMsgComReqDto.setObjectName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381944_1_55912
implementLoopSinglePersonSendMsgComReqDto.setMessageImportantLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1381949_1_55912
implementLoopSinglePersonSendMsgComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381952_1_55912
    }
if(addOfficialDocumentBodyComRespDto!=null){
      implementLoopSinglePersonSendMsgComReqDto.setEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381943_1_55912
implementLoopSinglePersonSendMsgComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381951_1_55912
    }
if(implementNotificationTypeMsgTempanAlyzeComRespDto!=null){
      implementLoopSinglePersonSendMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1477088_1_55912
implementLoopSinglePersonSendMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1477086_1_55912
implementLoopSinglePersonSendMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1477094_1_55912
    }

    /*D3执行循环单人发消息(公共)[8086]   */
    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getTableTypeCode(),"D3新增公文-D3执行循环单人发消息(公共)-内容表类型编码不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getEntityId(),"D3新增公文-D3执行循环单人发消息(公共)-内容表主键ID不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getObjectName(),"D3新增公文-D3执行循环单人发消息(公共)-对象名称不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageImportantLevel(),"D3新增公文-D3执行循环单人发消息(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentTypeCode(),"D3新增公文-D3执行循环单人发消息(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentId(),"D3新增公文-D3执行循环单人发消息(公共)-协同内容ID不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSurfaceContName(),"D3新增公文-D3执行循环单人发消息(公共)-协同内容名称不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSendMsgScene(),"D3新增公文-D3执行循环单人发消息(公共)-发送消息场景不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageTemplateCode(),"D3新增公文-D3执行循环单人发消息(公共)-消息模板标识不能为空",false);
Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3新增公文-D3执行循环单人发消息(公共)-消息标题模板引擎标识不能为空",false);
      implementLoopSinglePersonSendMsgComRespDto = messageService.implementLoopSinglePersonSendMsgCom(implementLoopSinglePersonSendMsgComReqDto)/*vcase invoke isSameApp*/;



           }
    }
if((reqDto!= null&& reqDto.getAppointWorkTaskArrangeInductionId() != null &&reqDto!= null&&  reqDto.getIsOpenWorkTask() !=null && reqDto.getIsOpenWorkTask().equals("TRUE"))) {
        //if((D3新增公文.指定工作任务安排人就职记录ID 值不等于空  and D3新增公文.是否开启工作任务 等于 是))  54165

QueryInductionDeptDetailComRespDto queryInductionDeptDetailComRespDto = null;
    QueryInductionDeptDetailComReqDto queryInductionDeptDetailComReqDto=new QueryInductionDeptDetailComReqDto();
  queryInductionDeptDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477125_1_59123
if(reqDto!=null){
      queryInductionDeptDetailComReqDto.setInductionRecordId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1477124_1_59123
    }

    /*D1查工作任务安排人身份人员ID[7829]   */
    Assert.isNull(queryInductionDeptDetailComReqDto.getInductionRecordId(),"D3新增公文-D1查工作任务安排人身份人员ID-就职记录ID不能为空",false);
Assert.isNull(queryInductionDeptDetailComReqDto.getSpaceId(),"D3新增公文-D1查工作任务安排人身份人员ID-创建于空间ID不能为空",false);
      queryInductionDeptDetailComRespDto = fwBaseInductionRecordClient.queryInductionDeptDetailCom(queryInductionDeptDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



ImplementSendTwoPersonConvMsgAndNumComRespDto implementSendTwoPersonConvMsgAndNumComRespDto = null;
    if(queryInductionDeptDetailComRespDto !=null&&addOfficialDocumentBodyComRespDto !=null){
          ImplementSendTwoPersonConvMsgAndNumComReqDto implementSendTwoPersonConvMsgAndNumComReqDto=new ImplementSendTwoPersonConvMsgAndNumComReqDto();
  implementSendTwoPersonConvMsgAndNumComReqDto.setSendMsgScene("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE");//sourceId:1477097_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477144_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477107_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477109_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setIsHandle("FALSE");//sourceId:1477117_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setHandleType("NEED_BUSINESS_OPERATION_HANDLING");//sourceId:1477118_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setPlatformReplace("FALSE");//sourceId:1477121_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setMessageImportantLevel(Long.valueOf(4));//CUSTOM_CONVENTION//sourceId:1477113_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setMessageTemplateCode("ARRANGE_WORK_TASK_INSTRUCT_TEMP");//CUSTOM_CONVENTION//sourceId:1477106_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldName("objectName");//CUSTOM_CONVENTION//sourceId:1477102_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setMsgTitleTemplateSemanticEngineCode("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1477101_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setComNumField(Long.valueOf(2));//CUSTOM_CONVENTION//sourceId:1477114_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477099_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1477100_1_59122
if(queryInductionDeptDetailComRespDto!=null){
      implementSendTwoPersonConvMsgAndNumComReqDto.setReceiveOriginalRoleMemberId(queryInductionDeptDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1477096_1_59122
    }
if(addOfficialDocumentBodyComRespDto!=null){
      implementSendTwoPersonConvMsgAndNumComReqDto.setEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477145_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setTableContentEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1547109_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477110_1_59122
    }
if(reqDto!=null){
      implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477111_1_59122
implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldValue(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477103_1_59122
    }

    /*D3执行发两人会话消息及数量(公共)[8262]   */
    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSendMsgScene(),"D3新增公文-D3执行发两人会话消息及数量(公共)-发送消息场景不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getReceiveOriginalRoleMemberId(),"D3新增公文-D3执行发两人会话消息及数量(公共)-接收方身份人员ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceCode(),"D3新增公文-D3执行发两人会话消息及数量(公共)-归属内容类型编码不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getEntityId(),"D3新增公文-D3执行发两人会话消息及数量(公共)-归属内容ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableTypeCode(),"D3新增公文-D3执行发两人会话消息及数量(公共)-冗余内容表类型编码不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableContentEntityId(),"D3新增公文-D3执行发两人会话消息及数量(公共)-冗余内容表主键ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentTypeCode(),"D3新增公文-D3执行发两人会话消息及数量(公共)-协同内容类型编码不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentId(),"D3新增公文-D3执行发两人会话消息及数量(公共)-协同内容ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceContName(),"D3新增公文-D3执行发两人会话消息及数量(公共)-协同内容名称不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getIsHandle(),"D3新增公文-D3执行发两人会话消息及数量(公共)-是否已处理不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getHandleType(),"D3新增公文-D3执行发两人会话消息及数量(公共)-处理类型不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getPlatformReplace(),"D3新增公文-D3执行发两人会话消息及数量(公共)-是否平台代操作不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageImportantLevel(),"D3新增公文-D3执行发两人会话消息及数量(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageTemplateCode(),"D3新增公文-D3执行发两人会话消息及数量(公共)-消息模板标识不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldName(),"D3新增公文-D3执行发两人会话消息及数量(公共)-第一个字段字段名不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldValue(),"D3新增公文-D3执行发两人会话消息及数量(公共)-第一个字段字段值不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMsgTitleTemplateSemanticEngineCode(),"D3新增公文-D3执行发两人会话消息及数量(公共)-消息标题模板引擎标识不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getComNumField(),"D3新增公文-D3执行发两人会话消息及数量(公共)-通用数值字段（整数型）不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSpaceId(),"D3新增公文-D3执行发两人会话消息及数量(公共)-创建于空间ID不能为空",false);
Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getAppId(),"D3新增公文-D3执行发两人会话消息及数量(公共)-创建于联盟应用ID不能为空",false);
      implementSendTwoPersonConvMsgAndNumComRespDto = messageService.implementSendTwoPersonConvMsgAndNumCom(implementSendTwoPersonConvMsgAndNumComReqDto)/*vcase invoke isSameApp*/;



           }
      }
      }
    }
else{
       //else  53520
      
//异常结束 53521
      throw new BizException("500","系统异常，请联系管理员！",false);
    }
//virtualUsage D2查平台文件存储根路径配置答案（公共）  71630
      QueryConfItemMatchAnswerDetailComRespDto queryConfItemMatchAnswerDetailComRespDto = null;
    QueryConfItemMatchAnswerDetailComReqDto queryConfItemMatchAnswerDetailComReqDto=new QueryConfItemMatchAnswerDetailComReqDto();
  queryConfItemMatchAnswerDetailComReqDto.setConfItemCode("FILE_STORAGE_ROOT_PATH");//CUSTOM_CONVENTION//sourceId:1935149_1_71630
queryConfItemMatchAnswerDetailComReqDto.setConfSchemeCode("COM_CONF_SCHEME");//CUSTOM_CONVENTION//sourceId:1935150_1_71630
queryConfItemMatchAnswerDetailComReqDto.setIsPlatData("TRUE");//sourceId:1935151_1_71630

    /*D2查平台文件存储根路径配置答案（公共）[2486]   */
    Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfItemCode(),"D3新增公文-D2查平台文件存储根路径配置答案（公共）-配置项标识不能为空",false);
Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfSchemeCode(),"D3新增公文-D2查平台文件存储根路径配置答案（公共）-配置方案标识不能为空",false);
Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getIsPlatData(),"D3新增公文-D2查平台文件存储根路径配置答案（公共）-是否标准答案不能为空",false);
      queryConfItemMatchAnswerDetailComRespDto = fwCompConfSchemeClient.queryConfItemMatchAnswerDetailCom(queryConfItemMatchAnswerDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



//virtualUsage D2执行清理个人用户无效文件(公共)  71631
      ImplementClearMemberInvalidDocComRespDto implementClearMemberInvalidDocComRespDto = null;
    if(queryConfItemMatchAnswerDetailComRespDto !=null){
          ImplementClearMemberInvalidDocComReqDto implementClearMemberInvalidDocComReqDto=new ImplementClearMemberInvalidDocComReqDto();
  implementClearMemberInvalidDocComReqDto.setIsCleanPersonalInvalidDocument("TRUE");//sourceId:1935156_1_71631
implementClearMemberInvalidDocComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1935154_1_71631
if(queryConfItemMatchAnswerDetailComRespDto!=null){
      implementClearMemberInvalidDocComReqDto.setFileStorageRootPath(queryConfItemMatchAnswerDetailComRespDto.getEndValue());//SimpleFieldAssign//sourceId:1935155_1_71631
    }

    /*D2执行清理个人用户无效文件(公共)[8792]   */
    Assert.isNull(implementClearMemberInvalidDocComReqDto.getIsCleanPersonalInvalidDocument(),"D3新增公文-D2执行清理个人用户无效文件(公共)-是否清理个人无效文档不能为空",false);
Assert.isNull(implementClearMemberInvalidDocComReqDto.getUserId(),"D3新增公文-D2执行清理个人用户无效文件(公共)-归属个人账号不能为空",false);
Assert.isNull(implementClearMemberInvalidDocComReqDto.getFileStorageRootPath(),"D3新增公文-D2执行清理个人用户无效文件(公共)-文件存储根路径不能为空",false);
      implementClearMemberInvalidDocComRespDto = fwCompUnstructuredDataClient.implementClearMemberInvalidDocCom(implementClearMemberInvalidDocComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



    }
AddOfficialDocumentRespDto retData = new AddOfficialDocumentRespDto();
  if(addOfficialDocumentBodyComRespDto_1!=null){
      retData.setOfficialDocumentId(addOfficialDocumentBodyComRespDto_1.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311571_1
    }


  
  
return retData;
  }
/**
   * D3-9修改公文主体(公共)[7923]
   * gen by moon at 12/6/2023, 6:25:45 AM
   */
  @Trace(operationName = "D3-9修改公文主体(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyCom(UpdateOfficialDocumentBodyComReqDto reqDto){
    
      
      //步骤0: 3-9-01修改公文 - updateOfficialDocument
     boolean bOOLEAN ;
    OmsOfficialDocument omsOfficialDocument=new OmsOfficialDocument();
  if(reqDto!=null){
      omsOfficialDocument.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311478_1
omsOfficialDocument.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311479_1
omsOfficialDocument.setOfficialDocumentFileAddress(reqDto.getOfficialDocumentFileAddress());//SimpleFieldAssign//sourceId:1311480_1
omsOfficialDocument.setAnnexAddress(reqDto.getAnnexAddress());//SimpleFieldAssign//sourceId:1311481_1
omsOfficialDocument.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1385415_1
omsOfficialDocument.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311482_1
omsOfficialDocument.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311483_1
omsOfficialDocument.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1311484_1
omsOfficialDocument.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311485_1
omsOfficialDocument.setArrangeWorkTaskTypeCode(reqDto.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1346304_1
omsOfficialDocument.setArrangeWorkTaskId(reqDto.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1346305_1
omsOfficialDocument.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311486_1
    }
  
    /*3-9-01修改公文[7922]   */
    Assert.isNull(omsOfficialDocument.getOfficialDocumentId(),"D3-9修改公文主体(公共)-3-9-01修改公文-公文ID不能为空",false);
      bOOLEAN = mOmsOfficialDocumentService.updateOfficialDocument(omsOfficialDocument)/*vcase invoke 本地 method 方法调用;*/;
      
      
      
    
UpdateOfficialDocumentBodyComRespDto retData = new UpdateOfficialDocumentBodyComRespDto();
  
  

  
  
return retData;
  }
/**
   * D3查询公文列表[7934]
   * gen by moon at 12/17/2023, 12:26:11 PM
   */
  @Trace(operationName = "D3查询公文列表")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryOfficialDocumentListRespDto queryOfficialDocumentList(QueryOfficialDocumentListReqDto reqDto){
    
      
      List<OmsOfficialDocument> listOmsOfficialDocument_1 =new ArrayList<>();
BatchQueryInductionRecordListComRespDto batchQueryInductionRecordListComRespDto_1 =null;
//步骤0: 3-9-01执行模糊查公文列表 - implementVagueQueryOfficialDocument
     List<OmsOfficialDocument> listOmsOfficialDocument =new ArrayList<>();
    ImplementVagueQueryOfficialDocumentReq implementVagueQueryOfficialDocumentReq=new ImplementVagueQueryOfficialDocumentReq();
  implementVagueQueryOfficialDocumentReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312389_1
if(reqDto!=null){
      implementVagueQueryOfficialDocumentReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312382_1
implementVagueQueryOfficialDocumentReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312383_1
implementVagueQueryOfficialDocumentReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312384_1
implementVagueQueryOfficialDocumentReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418248_1
implementVagueQueryOfficialDocumentReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312385_1
implementVagueQueryOfficialDocumentReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312386_1
implementVagueQueryOfficialDocumentReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1381573_1
implementVagueQueryOfficialDocumentReq.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420020_1
implementVagueQueryOfficialDocumentReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1312387_1
implementVagueQueryOfficialDocumentReq.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312388_1
    }
  
    /*3-9-01执行模糊查公文列表[7935]   */
    Assert.isNull(implementVagueQueryOfficialDocumentReq.getSpaceId(),"D3查询公文列表-3-9-01执行模糊查公文列表-创建于空间ID不能为空",false);
      listOmsOfficialDocument = mOmsOfficialDocumentService.implementVagueQueryOfficialDocument(implementVagueQueryOfficialDocumentReq)/*vcase invoke 本地 method 方法调用;*/;
      
      
      listOmsOfficialDocument_1 = listOmsOfficialDocument;
    
//步骤1: D1-3批量查询就职记录列表（公共） - batchQueryInductionRecordListCom
     BatchQueryInductionRecordListComRespDto batchQueryInductionRecordListComRespDto = null;
    if(listOmsOfficialDocument !=null&& !CollectionUtil.isEmpty(listOmsOfficialDocument)&& listOmsOfficialDocument.size()>0 ){
          BatchQueryInductionRecordListComReqDto batchQueryInductionRecordListComReqDto=new BatchQueryInductionRecordListComReqDto();
  if(listOmsOfficialDocument!= null&& !CollectionUtil.isEmpty(listOmsOfficialDocument)&&  listOmsOfficialDocument !=null&& !CollectionUtil.isEmpty(listOmsOfficialDocument)){
      batchQueryInductionRecordListComReqDto.setPerOrgInductionRecordList(listOmsOfficialDocument.stream().map(item->item.getCreateInductionId())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312426_1
    }
  
    /*D1-3批量查询就职记录列表（公共）[602]   */
    
      batchQueryInductionRecordListComRespDto = fwBaseInductionRecordClient.batchQueryInductionRecordListCom(batchQueryInductionRecordListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      batchQueryInductionRecordListComRespDto_1 = batchQueryInductionRecordListComRespDto;
           }
    
QueryOfficialDocumentListRespDto retData = new QueryOfficialDocumentListRespDto();
  //数据集融合  MoreListToOneSource
        if(listOmsOfficialDocument_1!= null&& !CollectionUtil.isEmpty(listOmsOfficialDocument_1) && !CollectionUtil.isEmpty(listOmsOfficialDocument_1) ){
          for (OmsOfficialDocument omsOfficialDocument : listOmsOfficialDocument_1) {
              OfficialDocumentDto retElm = new OfficialDocumentDto();
             retElm.setOfficialDocumentId(omsOfficialDocument.getOfficialDocumentId());//SimpleFieldAssign//sourceId:267749_2
retElm.setOfficialDocumentName(omsOfficialDocument.getOfficialDocumentName());//SimpleFieldAssign//sourceId:267750_2
retElm.setOfficialDocumentNum(omsOfficialDocument.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:267751_2
retElm.setReceiveRange(omsOfficialDocument.getReceiveRange());//SimpleFieldAssign//sourceId:267752_2
retElm.setWorkTaskIsArrange(omsOfficialDocument.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:284915_2
retElm.setCreateInductionId(omsOfficialDocument.getCreateInductionId());//SimpleFieldAssign//sourceId:267821_2
retElm.setSubjectLifeCycle(omsOfficialDocument.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:267753_2
retElm.setCreateTime(omsOfficialDocument.getCreateTime());//SimpleFieldAssign//sourceId:267754_2
              retData.getOfficialDocumentList().add(retElm);
               if(batchQueryInductionRecordListComRespDto_1!= null){
          for (PerOrgInductionRecordDto perOrgInductionRecordDto : batchQueryInductionRecordListComRespDto_1.getPerOrgInductionRecordList()) {
                if (perOrgInductionRecordDto.getInductionRecordId().equals(omsOfficialDocument.getCreateInductionId())) {
                 if(batchQueryInductionRecordListComRespDto_1!=null){
      retElm.setUserId(perOrgInductionRecordDto.getUserId());//SimpleFieldAssign//sourceId:267817_2
retElm.setIdCardName(perOrgInductionRecordDto.getIdCardName());//SimpleFieldAssign//sourceId:267818_2
retElm.setNickName(perOrgInductionRecordDto.getNickName());//SimpleFieldAssign//sourceId:267819_2
retElm.setUserFace(perOrgInductionRecordDto.getUserFace());//SimpleFieldAssign//sourceId:267820_2
    }
                }
            }
          }

          }
        }//sourceId:1312398_1
  

  
  
return retData;
  }
/**
   * D3删除公文[7941]
   * gen by moon at 6/9/2024, 1:09:23 AM
   */
  @Trace(operationName = "D3删除公文")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public DeleteOfficialDocumentRespDto deleteOfficialDocument(DeleteOfficialDocumentReqDto reqDto){
    
      
      //virtualUsage D3-9查询公文详情(公共)  53574
      QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
    QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto=new QueryOfficialDocumentDetailComReqDto();
  queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312486_1_53574
if(reqDto!=null){
      queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312485_1_53574
    }
  
    /*D3-9查询公文详情(公共)[7930]   */
    Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(),"D3删除公文-D3-9查询公文详情(公共)-公文ID不能为空",false);
Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(),"D3删除公文-D3-9查询公文详情(公共)-创建于空间ID不能为空",false);
      queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      
//virtualUsage D1执行生命周期判断(公共)  53575
      ImplementLifeCycleJudgmentComRespDto implementLifeCycleJudgmentComRespDto = null;
    if(queryOfficialDocumentDetailComRespDto !=null){
          ImplementLifeCycleJudgmentComReqDto implementLifeCycleJudgmentComReqDto=new ImplementLifeCycleJudgmentComReqDto();
  implementLifeCycleJudgmentComReqDto.setLifecyCycleOperationType("DELETE");//sourceId:1312490_1_53575
if(queryOfficialDocumentDetailComRespDto!=null){
      implementLifeCycleJudgmentComReqDto.setSubjectLifeCycle(queryOfficialDocumentDetailComRespDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1312491_1_53575
    }
  
    /*D1执行生命周期判断(公共)[7830]   */
    Assert.isNull(implementLifeCycleJudgmentComReqDto.getSubjectLifeCycle(),"D3删除公文-D1执行生命周期判断(公共)-主体生命周期不能为空",false);
Assert.isNull(implementLifeCycleJudgmentComReqDto.getLifecyCycleOperationType(),"D3删除公文-D1执行生命周期判断(公共)-生命周期操作类型不能为空",false);
      implementLifeCycleJudgmentComRespDto = fwBaseBatchClient.implementLifeCycleJudgmentCom(implementLifeCycleJudgmentComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
//virtualUsage D3-9删除公文(公共)  53576
      DeleteOfficialDocumentComRespDto deleteOfficialDocumentComRespDto = null;
    DeleteOfficialDocumentComReqDto deleteOfficialDocumentComReqDto=new DeleteOfficialDocumentComReqDto();
  if(reqDto!=null){
      deleteOfficialDocumentComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312454_1_53576
    }
  
    /*D3-9删除公文(公共)[7939]   */
    Assert.isNull(deleteOfficialDocumentComReqDto.getOfficialDocumentId(),"D3删除公文-D3-9删除公文(公共)-公文ID不能为空",false);
      deleteOfficialDocumentComRespDto = deleteOfficialDocumentCom(deleteOfficialDocumentComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      
if((queryOfficialDocumentDetailComRespDto!= null&& queryOfficialDocumentDetailComRespDto.getOfficialDocumentFileAddress() != null )) {
        //if(D3-9查询公文详情(公共).公文文件地址 值不等于空 )  53577

BatchDeleteDocRelOrDocComRespDto batchDeleteDocRelOrDocComRespDto = null;
    BatchDeleteDocRelOrDocComReqDto batchDeleteDocRelOrDocComReqDto=new BatchDeleteDocRelOrDocComReqDto();
  batchDeleteDocRelOrDocComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1857757_1_69802
batchDeleteDocRelOrDocComReqDto.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1857758_1_69802
batchDeleteDocRelOrDocComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1857764_1_69802
if(reqDto!=null){
      batchDeleteDocRelOrDocComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1857761_1_69802
    }

    /*D2批量删公文文档关系或文档(公共)[9755]   */
    Assert.isNull(batchDeleteDocRelOrDocComReqDto.getDocUseSceneCode(),"D3删除公文-D2批量删公文文档关系或文档(公共)-文档应用业务场景不能为空",false);
Assert.isNull(batchDeleteDocRelOrDocComReqDto.getDocUseType(),"D3删除公文-D2批量删公文文档关系或文档(公共)-文档用途类型不能为空",false);
Assert.isNull(batchDeleteDocRelOrDocComReqDto.getOwnEntityId(),"D3删除公文-D2批量删公文文档关系或文档(公共)-归属内容表主键ID不能为空",false);
Assert.isNull(batchDeleteDocRelOrDocComReqDto.getSpaceId(),"D3删除公文-D2批量删公文文档关系或文档(公共)-创建于空间ID不能为空",false);
      batchDeleteDocRelOrDocComRespDto = fwCompUnstructuredDataClient.batchDeleteDocRelOrDocCom(batchDeleteDocRelOrDocComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



      }
if((queryOfficialDocumentDetailComRespDto!= null&& queryOfficialDocumentDetailComRespDto.getAnnexAddress() != null )) {
        //if(D3-9查询公文详情(公共).附件地址 值不等于空 )  69804

BatchDeleteDocRelOrDocComRespDto batchDeleteDocRelOrDocComRespDto_1 = null;
    BatchDeleteDocRelOrDocComReqDto batchDeleteDocRelOrDocComReqDto_1=new BatchDeleteDocRelOrDocComReqDto();
  batchDeleteDocRelOrDocComReqDto_1.setDocUseSceneCode("WORK_TASKS");//sourceId:1857765_1_69805
batchDeleteDocRelOrDocComReqDto_1.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1857766_1_69805
batchDeleteDocRelOrDocComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1857772_1_69805
if(reqDto!=null){
      batchDeleteDocRelOrDocComReqDto_1.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1857769_1_69805
    }

    /*D2批量删公文附件文档关系或文档(公共)[9755]   */
    Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getDocUseSceneCode(),"D3删除公文-D2批量删公文附件文档关系或文档(公共)-文档应用业务场景不能为空",false);
Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getDocUseType(),"D3删除公文-D2批量删公文附件文档关系或文档(公共)-文档用途类型不能为空",false);
Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getOwnEntityId(),"D3删除公文-D2批量删公文附件文档关系或文档(公共)-归属内容表主键ID不能为空",false);
Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getSpaceId(),"D3删除公文-D2批量删公文附件文档关系或文档(公共)-创建于空间ID不能为空",false);
      batchDeleteDocRelOrDocComRespDto_1 = fwCompUnstructuredDataClient.batchDeleteDocRelOrDocCom(batchDeleteDocRelOrDocComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


        
      }
DeleteOfficialDocumentRespDto retData = new DeleteOfficialDocumentRespDto();
  
  

  
  
return retData;
  }
/**
   * D3查我接收的公文列表[7943]
   * gen by moon at 11/12/2023, 10:34:17 PM
   */
  @Trace(operationName = "D3查我接收的公文列表")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryMyReceiveOfficialDocumentListRespDto queryMyReceiveOfficialDocumentList(QueryMyReceiveOfficialDocumentListReqDto reqDto){
    
      
      List<OmsOfficialDocument> listOmsOfficialDocument_1 =new ArrayList<>();
//步骤0: D2查公文消息列表(公共) - queryOfficialDocumentMsgListCom
     QueryOfficialDocumentMsgListComRespDto queryOfficialDocumentMsgListComRespDto = null;
    QueryOfficialDocumentMsgListComReqDto queryOfficialDocumentMsgListComReqDto=new QueryOfficialDocumentMsgListComReqDto();
  
  
    /*D2查公文消息列表(公共)[7944]   */
    
      queryOfficialDocumentMsgListComRespDto = fwCompMessageClient.queryOfficialDocumentMsgListCom(queryOfficialDocumentMsgListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
    
//步骤1: 3-9-01批量查询模糊查公文 - batchQueryVagueQueryOfficialDocument
     List<OmsOfficialDocument> listOmsOfficialDocument =new ArrayList<>();
    if(queryOfficialDocumentMsgListComRespDto !=null){
          BatchQueryVagueQueryOfficialDocumentReq batchQueryVagueQueryOfficialDocumentReq=new BatchQueryVagueQueryOfficialDocumentReq();
  batchQueryVagueQueryOfficialDocumentReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312791_1
if(queryOfficialDocumentMsgListComRespDto!= null&&  queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList() !=null&& !CollectionUtil.isEmpty(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList())){
      batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentList(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList().stream().map(item->item.getEntityId())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312784_1
    }
if(reqDto!=null){
      batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312785_1
batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312786_1
batchQueryVagueQueryOfficialDocumentReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312787_1
batchQueryVagueQueryOfficialDocumentReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312788_1
batchQueryVagueQueryOfficialDocumentReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312789_1
batchQueryVagueQueryOfficialDocumentReq.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312790_1
    }
  
    /*3-9-01批量查询模糊查公文[7945]   */
    Assert.isNull(batchQueryVagueQueryOfficialDocumentReq.getSpaceId(),"D3查我接收的公文列表-3-9-01批量查询模糊查公文-创建于空间ID不能为空",false);
      listOmsOfficialDocument = mOmsOfficialDocumentService.batchQueryVagueQueryOfficialDocument(batchQueryVagueQueryOfficialDocumentReq)/*vcase invoke 本地 method 方法调用;*/;
      
      
      listOmsOfficialDocument_1 = listOmsOfficialDocument;
           }
    
QueryMyReceiveOfficialDocumentListRespDto retData = new QueryMyReceiveOfficialDocumentListRespDto();
  retData.setMyReceiveOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, MyReceiveOfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1312814_1
  

  
  
return retData;
  }
/**
   * D3查询公文详情[7932]
   * gen by moon at 5/27/2024, 10:31:13 PM
   */
  @Trace(operationName = "D3查询公文详情")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryOfficialDocumentDetailRespDto queryOfficialDocumentDetail(QueryOfficialDocumentDetailReqDto reqDto){


      QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto_1 =null;
QueryDocumentDetailComRespDto queryDocumentDetailComRespDto_1 =null;
QueryUnstructuredRelationshipInstanceListComRespDto queryUnstructuredRelationshipInstanceListComRespDto_1 =null;
//virtualUsage D3-9查询公文详情(公共)  53787
     QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
    QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto=new QueryOfficialDocumentDetailComReqDto();
  queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312304_1_53787
if(reqDto!=null){
      queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312298_1_53787
    }

    /*D3-9查询公文详情(公共)[7930]   */
    Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(),"D3查询公文详情-D3-9查询公文详情(公共)-公文ID不能为空",false);
Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(),"D3查询公文详情-D3-9查询公文详情(公共)-创建于空间ID不能为空",false);
      queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;


      queryOfficialDocumentDetailComRespDto_1 = queryOfficialDocumentDetailComRespDto;
if((queryOfficialDocumentDetailComRespDto!= null&& queryOfficialDocumentDetailComRespDto.getOfficialDocumentFileAddress() != null )) {
        //if(D3-9查询公文详情(公共).公文文件地址 值不等于空 )  53788

QueryUnstructuredRelationshipDetailComRespDto queryUnstructuredRelationshipDetailComRespDto = null;
    QueryUnstructuredRelationshipDetailComReqDto queryUnstructuredRelationshipDetailComReqDto=new QueryUnstructuredRelationshipDetailComReqDto();
  queryUnstructuredRelationshipDetailComReqDto.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1823156_1_69258
queryUnstructuredRelationshipDetailComReqDto.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1823153_1_69258
queryUnstructuredRelationshipDetailComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1823155_1_69258
queryUnstructuredRelationshipDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1823158_1_69258
if(reqDto!=null){
      queryUnstructuredRelationshipDetailComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1823157_1_69258
    }

    /*D2查询文档关系详情(公共)[9670]   */
    Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getOwnEntityId(),"D3查询公文详情-D2查询文档关系详情(公共)-归属内容主键ID不能为空",false);
Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getOwnTableTypeCode(),"D3查询公文详情-D2查询文档关系详情(公共)-归属内容类型编码不能为空",false);
Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getDocUseType(),"D3查询公文详情-D2查询文档关系详情(公共)-文档用途类型不能为空",false);
Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getDocUseSceneCode(),"D3查询公文详情-D2查询文档关系详情(公共)-文档应用业务场景不能为空",false);
Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getSpaceId(),"D3查询公文详情-D2查询文档关系详情(公共)-创建于空间ID不能为空",false);
      queryUnstructuredRelationshipDetailComRespDto = fwCompUnstructuredDataClient.queryUnstructuredRelationshipDetailCom(queryUnstructuredRelationshipDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



     QueryDocumentDetailComRespDto queryDocumentDetailComRespDto = null;
    if(queryUnstructuredRelationshipDetailComRespDto !=null){
          QueryDocumentDetailComReqDto queryDocumentDetailComReqDto=new QueryDocumentDetailComReqDto();
  if(queryUnstructuredRelationshipDetailComRespDto!=null){
      queryDocumentDetailComReqDto.setUnstructuredDataId(queryUnstructuredRelationshipDetailComRespDto.getUnstructuredDataId());//SimpleFieldAssign//sourceId:1313526_1_53790
    }

    /*D2查公文文档名称等[3168]   */
    Assert.isNull(queryDocumentDetailComReqDto.getUnstructuredDataId(),"D3查询公文详情-D2查公文文档名称等-文档ID不能为空",false);
      queryDocumentDetailComRespDto = fwCompUnstructuredDataClient.queryDocumentDetailCom(queryDocumentDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


      queryDocumentDetailComRespDto_1 = queryDocumentDetailComRespDto;
           }
      }
if((queryOfficialDocumentDetailComRespDto!= null&& queryOfficialDocumentDetailComRespDto.getAnnexAddress() != null )) {
        //if(D3-9查询公文详情(公共).附件地址 值不等于空 )  53793

QueryUnstructuredRelationshipInstanceListComRespDto queryUnstructuredRelationshipInstanceListComRespDto = null;
    QueryUnstructuredRelationshipInstanceListComReqDto queryUnstructuredRelationshipInstanceListComReqDto=new QueryUnstructuredRelationshipInstanceListComReqDto();
  queryUnstructuredRelationshipInstanceListComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1823185_1_69259
queryUnstructuredRelationshipInstanceListComReqDto.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1823186_1_69259
queryUnstructuredRelationshipInstanceListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1823187_1_69259
if(reqDto!=null){
      queryUnstructuredRelationshipInstanceListComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1823312_1_69259
    }

    /*D2查询文档关系实例列表(公共)[8781]   */
    Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getOwnEntityId(),"D3查询公文详情-D2查询文档关系实例列表(公共)-归属内容主键ID不能为空",false);
Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getDocUseSceneCode(),"D3查询公文详情-D2查询文档关系实例列表(公共)-文档应用业务场景不能为空",false);
Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getDocUseType(),"D3查询公文详情-D2查询文档关系实例列表(公共)-文档用途类型不能为空",false);
Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getSpaceId(),"D3查询公文详情-D2查询文档关系实例列表(公共)-创建于空间ID不能为空",false);
      queryUnstructuredRelationshipInstanceListComRespDto = fwCompUnstructuredDataClient.queryUnstructuredRelationshipInstanceListCom(queryUnstructuredRelationshipInstanceListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


      queryUnstructuredRelationshipInstanceListComRespDto_1 = queryUnstructuredRelationshipInstanceListComRespDto;
      }
QueryOfficialDocumentDetailRespDto retData = new QueryOfficialDocumentDetailRespDto();
  if(queryOfficialDocumentDetailComRespDto_1!=null){
      retData.setOfficialDocumentId(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312347_1
retData.setOfficialDocumentName(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312348_1
retData.setOfficialDocumentNum(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312349_1
retData.setNotificationDescription(queryOfficialDocumentDetailComRespDto_1.getNotificationDescription());//SimpleFieldAssign//sourceId:1420044_1
retData.setReceiveRange(queryOfficialDocumentDetailComRespDto_1.getReceiveRange());//SimpleFieldAssign//sourceId:1312350_1
retData.setOfficialDocumentFileAddress(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentFileAddress());//SimpleFieldAssign//sourceId:1313093_1
retData.setReceiveInductionId(queryOfficialDocumentDetailComRespDto_1.getReceiveInductionId());//SimpleFieldAssign//sourceId:1312351_1
retData.setNotificationType(queryOfficialDocumentDetailComRespDto_1.getNotificationType());//SimpleFieldAssign//sourceId:1418244_1
retData.setRemindLevel(queryOfficialDocumentDetailComRespDto_1.getRemindLevel());//SimpleFieldAssign//sourceId:1312352_1
retData.setIsOpenWorkTask(queryOfficialDocumentDetailComRespDto_1.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312353_1
retData.setWorkTaskIsArrange(queryOfficialDocumentDetailComRespDto_1.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312354_1
retData.setArrangeWorkTaskId(queryOfficialDocumentDetailComRespDto_1.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1419946_1
retData.setArrangeWorkTaskTypeCode(queryOfficialDocumentDetailComRespDto_1.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1419947_1
retData.setAppointWorkTaskArrangeInductionId(queryOfficialDocumentDetailComRespDto_1.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1312355_1
retData.setSubjectLifeCycle(queryOfficialDocumentDetailComRespDto_1.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1312356_1
retData.setCreateInductionId(queryOfficialDocumentDetailComRespDto_1.getCreateInductionId());//SimpleFieldAssign//sourceId:1313618_1
retData.setCreateTime(queryOfficialDocumentDetailComRespDto_1.getCreateTime());//SimpleFieldAssign//sourceId:1313619_1
retData.setOperationInductionId(queryOfficialDocumentDetailComRespDto_1.getOperationInductionId());//SimpleFieldAssign//sourceId:1312357_1
retData.setOperateTime(queryOfficialDocumentDetailComRespDto_1.getOperateTime());//SimpleFieldAssign//sourceId:1312358_1
    }
if(queryDocumentDetailComRespDto_1!=null){
      retData.setUnstructuredDataId(queryDocumentDetailComRespDto_1.getUnstructuredDataId());//SimpleFieldAssign//sourceId:1313547_1
retData.setUnstructuredDataName(queryDocumentDetailComRespDto_1.getUnstructuredDataName());//SimpleFieldAssign//sourceId:1313548_1
retData.setFileSize(queryDocumentDetailComRespDto_1.getFileSize());//SimpleFieldAssign//sourceId:1313549_1
retData.setPostfix(queryDocumentDetailComRespDto_1.getPostfix());//SimpleFieldAssign//sourceId:1313550_1
retData.setUnstructuredDataType(queryDocumentDetailComRespDto_1.getUnstructuredDataType());//SimpleFieldAssign//sourceId:1313551_1
    }
if(queryUnstructuredRelationshipInstanceListComRespDto_1!=null){
      retData.setAnnexList(queryUnstructuredRelationshipInstanceListComRespDto_1.getUnstructuredRelationshipList().stream().map(item -> BeanUtil.toBean(item, AnnexDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1312359_1
    }




return retData;
  }
/**
   * D3查接收的公文列表[7943]
   * gen by moon at 1/27/2024, 10:42:05 PM
   */
  @Trace(operationName = "D3查接收的公文列表")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryReceiveOfficialDocumentListRespDto queryReceiveOfficialDocumentList(QueryReceiveOfficialDocumentListReqDto reqDto){


      List<OmsOfficialDocument> listOmsOfficialDocument_1 =new ArrayList<>();
//virtualUsage D3分析通知类型行为类型(公共)  60330
      AnalysisNotificationTypeBehaviorTypeComRespDto analysisNotificationTypeBehaviorTypeComRespDto = null;
    AnalysisNotificationTypeBehaviorTypeComReqDto analysisNotificationTypeBehaviorTypeComReqDto=new AnalysisNotificationTypeBehaviorTypeComReqDto();
  if(reqDto!=null){
      analysisNotificationTypeBehaviorTypeComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1510987_1_60330
    }

    /*D3分析通知类型行为类型(公共)[8362]   */

      analysisNotificationTypeBehaviorTypeComRespDto = analysisNotificationTypeBehaviorTypeCom(analysisNotificationTypeBehaviorTypeComReqDto)/*vcase invoke 同服务,同domain*/;



if((reqDto!= null&& reqDto.getEntityId() != null )) {
        //if(D3查接收的公文列表.通道归属主体ID 值不等于空 )  53627

ImplementChannelTypeAnalyzeComRespDto implementChannelTypeAnalyzeComRespDto = null;
    ImplementChannelTypeAnalyzeComReqDto implementChannelTypeAnalyzeComReqDto=new ImplementChannelTypeAnalyzeComReqDto();
  if(reqDto!=null){
      implementChannelTypeAnalyzeComReqDto.setNewTableTypeCode(reqDto.getTableTypeCode());//SimpleFieldAssign//sourceId:1333913_1_54230
    }

    /*D2执行通道类型分析(公共)[7982]   */
    Assert.isNull(implementChannelTypeAnalyzeComReqDto.getNewTableTypeCode(),"D3查接收的公文列表-D2执行通道类型分析(公共)-通道归属主体内容类型编码不能为空",false);
      implementChannelTypeAnalyzeComRespDto = fwCompMessageClient.implementChannelTypeAnalyzeCom(implementChannelTypeAnalyzeComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



QueryChannelDetailComRespDto queryChannelDetailComRespDto = null;
    if(implementChannelTypeAnalyzeComRespDto !=null){
    QueryChannelDetailComReqDto queryChannelDetailComReqDto=new QueryChannelDetailComReqDto();
queryChannelDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1313673_1_53629
if(reqDto!=null){
      queryChannelDetailComReqDto.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1313672_1_53629
queryChannelDetailComReqDto.setTableTypeCode(reqDto.getTableTypeCode());//SimpleFieldAssign//sourceId:1331874_1_53629
    }
if(implementChannelTypeAnalyzeComRespDto!=null){
      queryChannelDetailComReqDto.setChannelTypeCode(implementChannelTypeAnalyzeComRespDto.getChannelTypeCode());//SimpleFieldAssign//sourceId:1331873_1_53629
    }

    /*D2查询通道详情(公共)[7101]   */
    Assert.isNull(queryChannelDetailComReqDto.getChannelTypeCode(),"D3查接收的公文列表-D2查询通道详情(公共)-通道类型编码不能为空",false);
Assert.isNull(queryChannelDetailComReqDto.getSpaceId(),"D3查接收的公文列表-D2查询通道详情(公共)-创建于空间ID不能为空",false);
      queryChannelDetailComRespDto = fwCompMessageClient.queryChannelDetailCom(queryChannelDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }
QueryOfficialDocumentMsgListComRespDto queryOfficialDocumentMsgListComRespDto = null;
    if(queryChannelDetailComRespDto !=null&&analysisNotificationTypeBehaviorTypeComRespDto !=null){
          QueryOfficialDocumentMsgListComReqDto queryOfficialDocumentMsgListComReqDto=new QueryOfficialDocumentMsgListComReqDto();
  if(queryChannelDetailComRespDto!=null){
      queryOfficialDocumentMsgListComReqDto.setMessageChannelId(queryChannelDetailComRespDto.getMessageChannelId());//SimpleFieldAssign//sourceId:1313665_1_53630
    }
if(analysisNotificationTypeBehaviorTypeComRespDto!=null){
      queryOfficialDocumentMsgListComReqDto.setBehaviorTypeCode(analysisNotificationTypeBehaviorTypeComRespDto.getBehaviorTypeCode());//SimpleFieldAssign//sourceId:1510327_1_53630
    }

    /*D2查公文消息列表(公共)[7944]   */

      queryOfficialDocumentMsgListComRespDto = fwCompMessageClient.queryOfficialDocumentMsgListCom(queryOfficialDocumentMsgListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }
List<OmsOfficialDocument> listOmsOfficialDocument =new ArrayList<>();
    if(queryOfficialDocumentMsgListComRespDto !=null){
          BatchQueryVagueQueryOfficialDocumentReq batchQueryVagueQueryOfficialDocumentReq=new BatchQueryVagueQueryOfficialDocumentReq();
  batchQueryVagueQueryOfficialDocumentReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312791_1_53631
if(queryOfficialDocumentMsgListComRespDto!= null&&  queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList() !=null&& !CollectionUtil.isEmpty(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList())){
      batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentList(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList().stream().map(item->item.getEntityId())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312784_1_53631
    }
if(reqDto!=null){
      batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312785_1_53631
batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312786_1_53631
batchQueryVagueQueryOfficialDocumentReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312787_1_53631
batchQueryVagueQueryOfficialDocumentReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418258_1_53631
batchQueryVagueQueryOfficialDocumentReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312788_1_53631
batchQueryVagueQueryOfficialDocumentReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312789_1_53631
batchQueryVagueQueryOfficialDocumentReq.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312790_1_53631
    }

    /*3-9-01批量查询模糊查公文[7945]   */
    Assert.isNull(batchQueryVagueQueryOfficialDocumentReq.getSpaceId(),"D3查接收的公文列表-3-9-01批量查询模糊查公文-创建于空间ID不能为空",false);
      listOmsOfficialDocument = mOmsOfficialDocumentService.batchQueryVagueQueryOfficialDocument(batchQueryVagueQueryOfficialDocumentReq)/*vcase invoke 本地 method 方法调用;*/;


      listOmsOfficialDocument_1 = listOmsOfficialDocument;
           }
      }
else if((reqDto!= null&& reqDto.getEntityId() == null )){
       //elseif(D3查接收的公文列表.通道归属主体ID 值等于空 )  53628

//ModelCode: receptionService
        ImplementGainInParameterFieldsRespDto receptionServiceRes = null;
    ImplementGainInParameterFieldsReqDto receptionServiceReq=new ImplementGainInParameterFieldsReqDto();
  receptionServiceReq.setOriginalRoleMemberId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecOriginalRoleMemberId());//CURRENT_ORIGINAL_ROLE_MEMBERID//sourceId:1314346_1_53633

    /*M3约定当前身份人员ID[6965]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getOriginalRoleMemberId(),"D3查接收的公文列表-M3约定当前身份人员ID-身份人员ID不能为空",false);
      receptionServiceRes = nbOfficialDocument.implementGainInParameterFields(receptionServiceReq);



QueryOfficialDocumentMsgListComRespDto queryOfficialDocumentMsgListComRespDto_2 = null;
    if(analysisNotificationTypeBehaviorTypeComRespDto !=null){
    QueryOfficialDocumentMsgListComReqDto queryOfficialDocumentMsgListComReqDto_1=new QueryOfficialDocumentMsgListComReqDto();
  if(receptionServiceRes!=null){
      queryOfficialDocumentMsgListComReqDto_1.setOriginalRoleMemberId(receptionServiceRes.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1313664_1_53632
    }
if(analysisNotificationTypeBehaviorTypeComRespDto!=null){
      queryOfficialDocumentMsgListComReqDto_1.setBehaviorTypeCode(analysisNotificationTypeBehaviorTypeComRespDto.getBehaviorTypeCode());//SimpleFieldAssign//sourceId:1510327_1_53632
    }

    /*D2查公文消息列表(公共)[7944]   */

      queryOfficialDocumentMsgListComRespDto_2 = fwCompMessageClient.queryOfficialDocumentMsgListCom(queryOfficialDocumentMsgListComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;



           }
List<OmsOfficialDocument> listOmsOfficialDocument_2 =new ArrayList<>();
    if(queryOfficialDocumentMsgListComRespDto_2 !=null){
          BatchQueryVagueQueryOfficialDocumentReq batchQueryVagueQueryOfficialDocumentReq_1=new BatchQueryVagueQueryOfficialDocumentReq();
  batchQueryVagueQueryOfficialDocumentReq_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312791_1_53634
if(queryOfficialDocumentMsgListComRespDto_2!= null&&  queryOfficialDocumentMsgListComRespDto_2.getOfficialDocumentMsgList() !=null&& !CollectionUtil.isEmpty(queryOfficialDocumentMsgListComRespDto_2.getOfficialDocumentMsgList())){
      batchQueryVagueQueryOfficialDocumentReq_1.setOfficialDocumentList(queryOfficialDocumentMsgListComRespDto_2.getOfficialDocumentMsgList().stream().map(item->item.getEntityId())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312784_1_53634
    }
if(reqDto!=null){
      batchQueryVagueQueryOfficialDocumentReq_1.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312785_1_53634
batchQueryVagueQueryOfficialDocumentReq_1.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312786_1_53634
batchQueryVagueQueryOfficialDocumentReq_1.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312787_1_53634
batchQueryVagueQueryOfficialDocumentReq_1.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418258_1_53634
batchQueryVagueQueryOfficialDocumentReq_1.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312788_1_53634
batchQueryVagueQueryOfficialDocumentReq_1.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312789_1_53634
batchQueryVagueQueryOfficialDocumentReq_1.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312790_1_53634
    }

    /*3-9-01批量查询模糊查公文[7945]   */
    Assert.isNull(batchQueryVagueQueryOfficialDocumentReq_1.getSpaceId(),"D3查接收的公文列表-3-9-01批量查询模糊查公文-创建于空间ID不能为空",false);
      listOmsOfficialDocument_2 = mOmsOfficialDocumentService.batchQueryVagueQueryOfficialDocument(batchQueryVagueQueryOfficialDocumentReq_1)/*vcase invoke 本地 method 方法调用;*/;


      listOmsOfficialDocument_1 = listOmsOfficialDocument_2;
           }
    }
QueryReceiveOfficialDocumentListRespDto retData = new QueryReceiveOfficialDocumentListRespDto();
  retData.setMyReceiveOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, MyReceiveOfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1312814_1




return retData;
  }
/**
   * D3执行回写公文安排的任务(公共)[7997]
   * gen by moon at 12/3/2023, 1:08:27 PM
   */
  @Trace(operationName = "D3执行回写公文安排的任务(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementWriteBackOffcialDocArrangeTaskComRespDto implementWriteBackOffcialDocArrangeTaskCom(ImplementWriteBackOffcialDocArrangeTaskComReqDto reqDto){


      //virtualUsage D3-9查公文详情(用于回写安排的任务)  54429
      QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
    QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto=new QueryOfficialDocumentDetailComReqDto();
  queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1346264_1_54429
if(reqDto!=null){
      queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1346258_1_54429
    }

    /*D3-9查公文详情(用于回写安排的任务)[7930]   */
    Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(),"D3执行回写公文安排的任务(公共)-D3-9查公文详情(用于回写安排的任务)-公文ID不能为空",false);
    Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(),"D3执行回写公文安排的任务(公共)-D3-9查公文详情(用于回写安排的任务)-创建于空间ID不能为空",false);
      queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;



if((queryOfficialDocumentDetailComRespDto!= null&& queryOfficialDocumentDetailComRespDto.getOfficialDocumentId() != null )) {
        //if(D3-9查公文详情(用于回写安排的任务).公文ID 值不等于空 )  54430

UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto = null;
    if(queryOfficialDocumentDetailComRespDto !=null){
          UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto=new UpdateOfficialDocumentBodyComReqDto();
  updateOfficialDocumentBodyComReqDto.setWorkTaskIsArrange("TRUE");//sourceId:1346301_1_54431
if(queryOfficialDocumentDetailComRespDto!=null){
      updateOfficialDocumentBodyComReqDto.setOfficialDocumentId(queryOfficialDocumentDetailComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1346291_1_54431
    }
if(reqDto!=null){
      updateOfficialDocumentBodyComReqDto.setArrangeWorkTaskId(reqDto.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1346309_1_54431
updateOfficialDocumentBodyComReqDto.setArrangeWorkTaskTypeCode(reqDto.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1346308_1_54431
    }

    /*D3-9修改公文主体(公共)[7923]   */
    Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentId(),"D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-公文ID不能为空",false);
Assert.isNull(updateOfficialDocumentBodyComReqDto.getArrangeWorkTaskId(),"D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-安排的工作任务ID不能为空",false);
Assert.isNull(updateOfficialDocumentBodyComReqDto.getArrangeWorkTaskTypeCode(),"D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-安排的工作任务类型编码不能为空",false);
Assert.isNull(updateOfficialDocumentBodyComReqDto.getWorkTaskIsArrange(),"D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-工作任务是否已安排不能为空",false);
      updateOfficialDocumentBodyComRespDto = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;



           }
QueryMessageDetailComRespDto queryMessageDetailComRespDto = null;
    QueryMessageDetailComReqDto queryMessageDetailComReqDto=new QueryMessageDetailComReqDto();
  queryMessageDetailComReqDto.setMessageTemplateCode("ARRANGE_WORK_TASK_INSTRUCT");//CUSTOM_CONVENTION//sourceId:1369494_1_55221
queryMessageDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1369493_1_55221
if(reqDto!=null){
      queryMessageDetailComReqDto.setEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1369490_1_55221
    }

    /*D2-查询消息详情(公共)[7526]   */
    Assert.isNull(queryMessageDetailComReqDto.getEntityId(),"D3执行回写公文安排的任务(公共)-D2-查询消息详情(公共)-归属内容ID不能为空",false);
Assert.isNull(queryMessageDetailComReqDto.getMessageTemplateCode(),"D3执行回写公文安排的任务(公共)-D2-查询消息详情(公共)-消息模板标识不能为空",false);
Assert.isNull(queryMessageDetailComReqDto.getSpaceId(),"D3执行回写公文安排的任务(公共)-D2-查询消息详情(公共)-创建于空间ID不能为空",false);
      queryMessageDetailComRespDto = fwCompMessageClient.queryMessageDetailCom(queryMessageDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



if((queryMessageDetailComRespDto!= null&& queryMessageDetailComRespDto.getMessageId() != null &&queryMessageDetailComRespDto!= null&&  queryMessageDetailComRespDto.getIsHandle() !=null && queryMessageDetailComRespDto.getIsHandle().equals("FALSE"))) {
        //if((D2-查询消息详情(公共).消息ID 值不等于空  and D2-查询消息详情(公共).是否已处理 等于 否))  55233

ImplementMsgDisposeStateComRespDto implementMsgDisposeStateComRespDto = null;
    if(queryMessageDetailComRespDto !=null){
          ImplementMsgDisposeStateComReqDto implementMsgDisposeStateComReqDto=new ImplementMsgDisposeStateComReqDto();
  implementMsgDisposeStateComReqDto.setIsHandle("TRUE");//sourceId:1369452_1_55234
if(queryMessageDetailComRespDto!=null){
      implementMsgDisposeStateComReqDto.setMessageId(queryMessageDetailComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1369451_1_55234
    }

    /*D2-执行消息处理状态(公共)[7544]   */
    Assert.isNull(implementMsgDisposeStateComReqDto.getMessageId(),"D3执行回写公文安排的任务(公共)-D2-执行消息处理状态(公共)-消息ID不能为空",false);
Assert.isNull(implementMsgDisposeStateComReqDto.getIsHandle(),"D3执行回写公文安排的任务(公共)-D2-执行消息处理状态(公共)-是否已处理不能为空",false);
      implementMsgDisposeStateComRespDto = fwCompMessageClient.implementMsgDisposeStateCom(implementMsgDisposeStateComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }
           }
      }
ImplementWriteBackOffcialDocArrangeTaskComRespDto retData = new ImplementWriteBackOffcialDocArrangeTaskComRespDto();





return retData;
  }
/**
   * D3查询未安排的公文列表[8062]
   * gen by moon at 12/15/2023, 2:41:37 PM
   */
  @Trace(operationName = "D3查询未安排的公文列表")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryUnscheduledOfficialDocListRespDto queryUnscheduledOfficialDocList(QueryUnscheduledOfficialDocListReqDto reqDto){


      QueryOfficialDocumentBodyListComRespDto queryOfficialDocumentBodyListComRespDto_1 =null;
//步骤0: D3查询公文主体列表(公共) - queryOfficialDocumentBodyListCom
     QueryOfficialDocumentBodyListComRespDto queryOfficialDocumentBodyListComRespDto = null;
    QueryOfficialDocumentBodyListComReqDto queryOfficialDocumentBodyListComReqDto=new QueryOfficialDocumentBodyListComReqDto();
  queryOfficialDocumentBodyListComReqDto.setIsOpenWorkTask("TRUE");//sourceId:1368854_1
queryOfficialDocumentBodyListComReqDto.setWorkTaskIsArrange("FALSE");//sourceId:1368855_1
queryOfficialDocumentBodyListComReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1368857_1
if(reqDto!=null){
      queryOfficialDocumentBodyListComReqDto.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1368859_1
queryOfficialDocumentBodyListComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418254_1
    }

    /*D3查询公文主体列表(公共)[8063]   */
    Assert.isNull(queryOfficialDocumentBodyListComReqDto.getAppointWorkTaskArrangeInductionId(),"D3查询未安排的公文列表-D3查询公文主体列表(公共)-指定工作任务安排人就职记录ID不能为空",false);
Assert.isNull(queryOfficialDocumentBodyListComReqDto.getIsOpenWorkTask(),"D3查询未安排的公文列表-D3查询公文主体列表(公共)-是否开启工作任务不能为空",false);
Assert.isNull(queryOfficialDocumentBodyListComReqDto.getWorkTaskIsArrange(),"D3查询未安排的公文列表-D3查询公文主体列表(公共)-工作任务是否已安排不能为空",false);
Assert.isNull(queryOfficialDocumentBodyListComReqDto.getSubjectLifeCycle(),"D3查询未安排的公文列表-D3查询公文主体列表(公共)-主体生命周期不能为空",false);
      queryOfficialDocumentBodyListComRespDto = queryOfficialDocumentBodyListCom(queryOfficialDocumentBodyListComReqDto)/*vcase invoke 同服务,同domain*/;


      queryOfficialDocumentBodyListComRespDto_1 = queryOfficialDocumentBodyListComRespDto;

QueryUnscheduledOfficialDocListRespDto retData = new QueryUnscheduledOfficialDocListRespDto();
  if(queryOfficialDocumentBodyListComRespDto_1!=null){
      retData.setOfficialDocumentList(queryOfficialDocumentBodyListComRespDto_1.getOfficialDocumentList().stream().map(item -> BeanUtil.toBean(item, OfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1368861_1
    }




return retData;
  }
/**
   * D3查询公文主体列表(公共)[8063]
   * gen by moon at 12/15/2023, 2:41:44 PM
   */
  @Trace(operationName = "D3查询公文主体列表(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryOfficialDocumentBodyListComRespDto queryOfficialDocumentBodyListCom(QueryOfficialDocumentBodyListComReqDto reqDto){


      List<OmsOfficialDocument> listOmsOfficialDocument_1 =new ArrayList<>();
//步骤0: 3-9-01查询公文列表 - queryOfficialDocumentList
     List<OmsOfficialDocument> listOmsOfficialDocument =new ArrayList<>();
    QueryOfficialDocumentListReq queryOfficialDocumentListReq=new QueryOfficialDocumentListReq();
  queryOfficialDocumentListReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1368828_1
if(reqDto!=null){
      queryOfficialDocumentListReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1368825_1
queryOfficialDocumentListReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1368829_1
queryOfficialDocumentListReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1368831_1
queryOfficialDocumentListReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418252_1
queryOfficialDocumentListReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1368832_1
queryOfficialDocumentListReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1368833_1
queryOfficialDocumentListReq.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1368845_1
queryOfficialDocumentListReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1368827_1
queryOfficialDocumentListReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1368826_1
    }

    /*3-9-01查询公文列表[7926]   */
    Assert.isNull(queryOfficialDocumentListReq.getSpaceId(),"D3查询公文主体列表(公共)-3-9-01查询公文列表-创建于空间ID不能为空",false);
      listOmsOfficialDocument = mOmsOfficialDocumentService.queryOfficialDocumentList(queryOfficialDocumentListReq)/*vcase invoke 本地 method 方法调用;*/;


      listOmsOfficialDocument_1 = listOmsOfficialDocument;

QueryOfficialDocumentBodyListComRespDto retData = new QueryOfficialDocumentBodyListComRespDto();
  retData.setOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, OfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1368843_1




return retData;
  }
/**
   * D3执行通知类型消息模板分析(公共)[8153]
   * gen by moon at 1/2/2024, 12:54:39 PM
   */
  @Trace(operationName = "D3执行通知类型消息模板分析(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementNotificationTypeMsgTempanAlyzeComRespDto implementNotificationTypeMsgTempanAlyzeCom(ImplementNotificationTypeMsgTempanAlyzeComReqDto reqDto){


      ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_5 =null;
if((reqDto!= null&&  reqDto.getNotificationType() !=null && reqDto.getNotificationType().equals("OFFICIAL_DOCUMENT"))) {
        //if(D3执行通知类型消息模板分析(公共).通知类型 等于 公文)  56667

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq.setMsgTitleTemplateSemanticEngineCode("ISSUE_OFFCIAL_DOC_TITLE");//CUSTOM_CONVENTION//sourceId:1464868_1_56673

    /*M3约定下发公文标题语义引擎模板[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文标题语义引擎模板-消息标题模板引擎标识不能为空",false);
      receptionServiceRes = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq);



if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("EVERYONE"))) {
        //if(D3执行通知类型消息模板分析(公共).接收范围 等于 所有人)  56672

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_2 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_1=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_1.setSendMsgScene("ISSUE_OFFICIAL_DOC_SEND_EVERYONE");//sourceId:1464850_1_56674
receptionServiceReq_1.setMessageTemplateCode("ISSUE_OFFCIAL_DOC_ORG_GROUP");//CUSTOM_CONVENTION//sourceId:1464896_1_56674

    /*M3约定下发公文给所有人[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_1.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文给所有人-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_1.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文给所有人-消息模板标识不能为空",false);
      receptionServiceRes_2 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_1);



//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_4 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_2=new ImplementTypeCodeFieldsAcceptReqDto();
  if(receptionServiceRes_2!=null){
      receptionServiceReq_2.setSendMsgScene(receptionServiceRes_2.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56675
receptionServiceReq_2.setMessageTemplateCode(receptionServiceRes_2.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56675
    }
  if(receptionServiceRes!=null){
      receptionServiceReq_2.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56675
    }

    /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_2.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_2.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_2.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_4 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_2);


      receptionServiceRes_5 = receptionServiceRes_4;
      }
else if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("DEPT"))){
       //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 部门)  56676

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_6 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_3=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_3.setSendMsgScene("ISSUE_OFFICIAL_DOC_SEND_DEPT");//sourceId:1464855_1_56677
receptionServiceReq_3.setMessageTemplateCode("ISSUE_OFFCIAL_DOC_DEPT_GROUP");//CUSTOM_CONVENTION//sourceId:1464900_1_56677

    /*M3约定下发公文给部门[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_3.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文给部门-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_3.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文给部门-消息模板标识不能为空",false);
      receptionServiceRes_6 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_3);



//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_8 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_4=new ImplementTypeCodeFieldsAcceptReqDto();
  if(receptionServiceRes_6!=null){
      receptionServiceReq_4.setSendMsgScene(receptionServiceRes_6.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56678
receptionServiceReq_4.setMessageTemplateCode(receptionServiceRes_6.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56678
    }
  if(receptionServiceRes!=null){
      receptionServiceReq_4.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56678
    }

    /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_4.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_4.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_4.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_8 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_4);


      receptionServiceRes_5 = receptionServiceRes_8;
    }
else if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("PERSON"))){
       //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 个人)  56683

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_9 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_5=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_5.setSendMsgScene("ISSUE_OFFICIAL_DOC_SEND_PERSON");//sourceId:1464857_1_56688
receptionServiceReq_5.setMessageTemplateCode("ISSUE_OFFCIAL_DOC_TWO_PEOPLE_CHAT");//CUSTOM_CONVENTION//sourceId:1464902_1_56688

    /*M3约定下发公文给个人[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_5.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文给个人-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_5.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发公文给个人-消息模板标识不能为空",false);
      receptionServiceRes_9 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_5);



//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_11 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_6=new ImplementTypeCodeFieldsAcceptReqDto();
  if(receptionServiceRes_9!=null){
      receptionServiceReq_6.setSendMsgScene(receptionServiceRes_9.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56684
receptionServiceReq_6.setMessageTemplateCode(receptionServiceRes_9.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56684
    }
  if(receptionServiceRes!=null){
      receptionServiceReq_6.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56684
    }

    /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_6.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_6.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_6.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_11 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_6);


      receptionServiceRes_5 = receptionServiceRes_11;
    }
      }
else if((reqDto!= null&&  reqDto.getNotificationType() !=null && reqDto.getNotificationType().equals("NOTIFICATION"))){
       //elseif(D3执行通知类型消息模板分析(公共).通知类型 等于 通知)  56668

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_12 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_7=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_7.setMsgTitleTemplateSemanticEngineCode("ISSUE_NOTIFICATION_TITLE");//CUSTOM_CONVENTION//sourceId:1464872_1_56679

    /*M3约定通知引擎模板标识[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_7.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3约定通知引擎模板标识-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_12 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_7);



if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("EVERYONE"))) {
        //if(D3执行通知类型消息模板分析(公共).接收范围 等于 所有人)  56680

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_14 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_8=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_8.setSendMsgScene("ISSUE_NOTIFICATION_SEND_EVERYONE");//sourceId:1464859_1_56696
receptionServiceReq_8.setMessageTemplateCode("ISSUE_NOTIFICATION_ORG_GROUP");//CUSTOM_CONVENTION//sourceId:1465226_1_56696

    /*M3约定下发通知给所有人[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_8.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3约定下发通知给所有人-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_8.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发通知给所有人-消息模板标识不能为空",false);
      receptionServiceRes_14 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_8);



//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_16 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_9=new ImplementTypeCodeFieldsAcceptReqDto();
  if(receptionServiceRes_14!=null){
      receptionServiceReq_9.setSendMsgScene(receptionServiceRes_14.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56685
receptionServiceReq_9.setMessageTemplateCode(receptionServiceRes_14.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56685
    }
  if(receptionServiceRes_12!=null){
      receptionServiceReq_9.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_12.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56685
    }

    /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_9.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_9.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_9.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_16 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_9);


      receptionServiceRes_5 = receptionServiceRes_16;
      }
else if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("DEPT"))){
       //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 部门)  56681

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_17 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_10=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_10.setSendMsgScene("ISSUE_NOTIFICATION_SEND_DEPT");//sourceId:1464861_1_56697
receptionServiceReq_10.setMessageTemplateCode("ISSUE_NOTIFICATION_DEPT_GROUP");//CUSTOM_CONVENTION//sourceId:1465228_1_56697

    /*M3约定下发通知给部门[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_10.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3约定下发通知给部门-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_10.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发通知给部门-消息模板标识不能为空",false);
      receptionServiceRes_17 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_10);



//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_19 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_11=new ImplementTypeCodeFieldsAcceptReqDto();
  if(receptionServiceRes_17!=null){
      receptionServiceReq_11.setSendMsgScene(receptionServiceRes_17.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56686
receptionServiceReq_11.setMessageTemplateCode(receptionServiceRes_17.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56686
    }
  if(receptionServiceRes_12!=null){
      receptionServiceReq_11.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_12.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56686
    }

    /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_11.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_11.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_11.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_19 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_11);


      receptionServiceRes_5 = receptionServiceRes_19;
    }
else if((reqDto!= null&&  reqDto.getReceiveRange() !=null && reqDto.getReceiveRange().equals("PERSON"))){
       //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 个人)  56682

//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_20 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_12=new ImplementTypeCodeFieldsAcceptReqDto();
  receptionServiceReq_12.setSendMsgScene("ISSUE_NOTIFICATION_SEND_PERSON");//sourceId:1464863_1_56698
receptionServiceReq_12.setMessageTemplateCode("ISSUE_NOTIFICATION_TWO_PEOPLE_CHAT");//CUSTOM_CONVENTION//sourceId:1465230_1_56698

    /*M3约定下发通知给个人[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_12.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3约定下发通知给个人-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_12.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3约定下发通知给个人-消息模板标识不能为空",false);
      receptionServiceRes_20 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_12);



//ModelCode: receptionService
        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_22 = null;
    ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_13=new ImplementTypeCodeFieldsAcceptReqDto();
  if(receptionServiceRes_20!=null){
      receptionServiceReq_13.setSendMsgScene(receptionServiceRes_20.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56687
receptionServiceReq_13.setMessageTemplateCode(receptionServiceRes_20.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56687
    }
  if(receptionServiceRes_12!=null){
      receptionServiceReq_13.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_12.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56687
    }

    /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_13.getSendMsgScene(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq_13.getMessageTemplateCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_13.getMsgTitleTemplateSemanticEngineCode(),"D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_22 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_13);


      receptionServiceRes_5 = receptionServiceRes_22;
    }
    }
ImplementNotificationTypeMsgTempanAlyzeComRespDto retData = new ImplementNotificationTypeMsgTempanAlyzeComRespDto();
  if(receptionServiceRes_5!=null){
      retData.setSendMsgScene(receptionServiceRes_5.getSendMsgScene());//SimpleFieldAssign//sourceId:1464874_1
retData.setMessageTemplateCode(receptionServiceRes_5.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1465232_1
retData.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_5.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464875_1
    }




return retData;
  }
/**
   * D3分析通知类型行为类型(公共)[8362]
   * gen by moon at 1/27/2024, 10:23:48 PM
   */
  @Trace(operationName = "D3分析通知类型行为类型(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public AnalysisNotificationTypeBehaviorTypeComRespDto analysisNotificationTypeBehaviorTypeCom(AnalysisNotificationTypeBehaviorTypeComReqDto reqDto){


      ImplementFourthReceivingFieldRespDto receptionServiceRes_3 =null;
//virtualUsage M3约定公文通知行为类型  60326
      //ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes = null;
    ImplementFourthReceivingFieldReqDto receptionServiceReq=new ImplementFourthReceivingFieldReqDto();
  receptionServiceReq.setCustomField1("ISSUE_OFFCIAL_DOC");//CUSTOM_CONVENTION//sourceId:1510974_1_60326
receptionServiceReq.setCustomField2("ISSUE_NOTIFICATION");//CUSTOM_CONVENTION//sourceId:1510975_1_60326

    /*M3约定公文通知行为类型[8259]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getCustomField1(),"D3分析通知类型行为类型(公共)-M3约定公文通知行为类型-自定义字段1不能为空",false);
Assert.isNull(receptionServiceReq.getCustomField2(),"D3分析通知类型行为类型(公共)-M3约定公文通知行为类型-自定义字段2不能为空",false);
      receptionServiceRes = nbOfficialDocument.implementFourthReceivingField(receptionServiceReq);



if((reqDto!= null&&  reqDto.getNotificationType() !=null && reqDto.getNotificationType().equals("OFFICIAL_DOCUMENT"))) {
        //if(D3分析通知类型行为类型(公共).通知类型 等于 公文)  60325

//ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes_2 = null;
    ImplementFourthReceivingFieldReqDto receptionServiceReq_1=new ImplementFourthReceivingFieldReqDto();
  if(receptionServiceRes!=null){
      receptionServiceReq_1.setBehaviorTypeCode(receptionServiceRes.getCustomField1());//SimpleFieldAssign//sourceId:1510982_1_60328
    }

    /*M3接收行为类型出参[8259]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_1.getBehaviorTypeCode(),"D3分析通知类型行为类型(公共)-M3接收行为类型出参-行为类型编码不能为空",false);
      receptionServiceRes_2 = nbOfficialDocument.implementFourthReceivingField(receptionServiceReq_1);


      receptionServiceRes_3 = receptionServiceRes_2;
      }
else if((reqDto!= null&&  reqDto.getNotificationType() !=null && reqDto.getNotificationType().equals("NOTIFICATION"))){
       //elseif(D3分析通知类型行为类型(公共).通知类型 等于 通知)  60327

//ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes_4 = null;
    ImplementFourthReceivingFieldReqDto receptionServiceReq_2=new ImplementFourthReceivingFieldReqDto();
  if(receptionServiceRes!=null){
      receptionServiceReq_2.setBehaviorTypeCode(receptionServiceRes.getCustomField2());//SimpleFieldAssign//sourceId:1510982_1_60329
    }

    /*M3接收行为类型出参[8259]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_2.getBehaviorTypeCode(),"D3分析通知类型行为类型(公共)-M3接收行为类型出参-行为类型编码不能为空",false);
      receptionServiceRes_4 = nbOfficialDocument.implementFourthReceivingField(receptionServiceReq_2);


      receptionServiceRes_3 = receptionServiceRes_4;
    }
AnalysisNotificationTypeBehaviorTypeComRespDto retData = new AnalysisNotificationTypeBehaviorTypeComRespDto();
  if(receptionServiceRes_3!=null){
      retData.setBehaviorTypeCode(receptionServiceRes_3.getBehaviorTypeCode());//SimpleFieldAssign//sourceId:1510986_1
    }




return retData;
  }
  //
}
